go-rabbitmq: Consumer won't reconnect

Hi,

Somehow when network got disconnected for a minutes or so and then network up again, I got a log

gorabbit: rabbit consumer goroutine closed

After that, consumer stops receiving new message. Why wont it reconnect?

I’m using version 0.6.2, and my code is (more or less) like this

rabbitmqConsumer, err := rabbitmq.NewConsumer(config.constructURL(), amqp.Config{}, rabbitmq.WithConsumerOptionsLogging)
...
rabbitmqConsumer.StartConsuming(
  func(message rabbitmq.Delivery) bool {
    return true
  },
  "",
  []string{""},
  func(options *rabbitmq.ConsumeOptions) {
    options.QueueExclusive = true
    options.ConsumerExclusive = true
    options.QueueDurable = true
    options.BindingExchange = &rabbitmq.BindingExchangeOptions{
      Name:    "my_rabbitmq_topic",
      Kind:    "fanout",
      Durable: true,
    }
  },
)

About this issue

Original URL
State: closed
Created 3 years ago
Reactions: 1
Comments: 31 (16 by maintainers)

Most upvoted comments

I’m sorry I’m not able to reproduce this. Are you guys sure you aren’t missing some logging, and that messages are actually being sent?

This is my test process. Let me know what to do differently to see what you’re seeing:

Start example consumer connected to local rabbitmq

Close local rabbit server

Watch consumer auto reconnect

Start publisher, watch the consumer consume the messages

Close cleanly both the publisher and consumer

Note that this is not my use case. My case is:

Start remote server
Start local consumer
Watch consumer receive messages
…long period of inactivity…
See message gorabbit: rabbit consumer goroutine closed in the consumer log
Publish more messages
messages are not picked up by consumer
Stop local consumer
Start new local consumer
Messages are received

So it seems like the consumer gets bored and drops the connection and does not reconnect.

tmalaher on Mar 4, 2022