Geek Answers Handbook

Why is there a duplicate consumer after reconnecting to RabbitMQ?

I use:

  • RabbitMQ 3.5.1
  • Java RabbitMQ Client
  • RabbitMQ Dual Instance Cluster

I have a queue that:

  • Durable = False
  • Exceptional = False
  • Auto Delete = True
  • Queue mirroring did not affect the results

My application has an asynchronous consumer receiving messages through a callback. The problem occurs when I try to simulate a connection failure by disconnecting the network connection with the broker. After the connection is established, the queue (in the web administration interface) shows two consumers connected to the same consumer tag, but with different port numbers.

, , , . , - , ?

+4
1

, 580 , , .

, . heartbeat Dead TCP Connections Heartbeats

RabbitMQ.

+1

More articles:


All Articles