You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I'm running a simple pubsub application in k8s cluster. The publisher and the subscriber are threads in the same process.
The publisher publishes messages to 3 fanout exchanges every 0.5 seconds. Each exchange has 1:1 binding to a queue.
When I scale up the application to 10 pods, I'm observing (not deterministically, but very often) an error unexpected command received returned by Channel.QueueBind(...). After that the management UI shows incorrect binding.
I'm also seeing error operation basic.consume caused a connection exception not_allowed: "attempt to reuse consumer tag in rabbitmq server log at the same time.
The text was updated successfully, but these errors were encountered:
I'm running a simple pubsub application in k8s cluster. The publisher and the subscriber are threads in the same process.
The publisher publishes messages to 3 fanout exchanges every 0.5 seconds. Each exchange has 1:1 binding to a queue.
When I scale up the application to 10 pods, I'm observing (not deterministically, but very often) an error
unexpected command received
returned byChannel.QueueBind(...)
. After that the management UI shows incorrect binding.I'm also seeing error
operation basic.consume caused a connection exception not_allowed: "attempt to reuse consumer tag
in rabbitmq server log at the same time.The text was updated successfully, but these errors were encountered: