Access refused when trying to bind router to queue

[trancong12102]

Dear sir, I have "ACCESS_REFUSED - operation not permitted on the default exchange" error when trying your consumer example. This is my code

consumer, err := rabbitmq.NewConsumer(env.RabbitMqUrl)
    handleError(err, "Create consumer", true)

    err = consumer.StartConsuming(
        func(d rabbitmq.Delivery) bool {
            log.Printf("Consumed: %s", d.Body)

            return true
        },
        "runner_sandbox_worker",
        []string{"runner_sandbox_routing"},
        rabbitmq.WithConsumeOptionsConcurrency(10),
        rabbitmq.WithConsumeOptionsQueueDurable,
        rabbitmq.WithConsumeOptionsQuorum,
    )
    handleError(err, "Start consuming", true)

Thanks!

[wagslane]

Thanks! v0.4.0 will solve this, the examples are also updated to include an exchange