amqp091-go-repro-106

Repro code for rabbitmq/amqp091-go/issues/106

How to run this code

You need 3 terminals and RabbitMQ running, listening in the default AMQP port 5672.

Prepare the following commands in different terminals:

go run consumer/consumer.go --stop

The above will exit after 3 seconds. Don't hit enter until you have all them ready :-) Or change the code in this line:

amqp091-go-repro-106/consumer/consumer.go

Line 56 in f65a798

<-time.After(time.Second*3)

go run consumer/consumer.go

The above won't exit. It should be "ready" consumer. First one should be active.

go run producer/producer.go

The above will publish 100,000 messages and exit. Producer relies on Consumers to create the test queue.