<div dir="ltr">I have created clustered environment with two nodes and started producer and consumer at the same time. After sometime stopped one node but consumer is not running on other rabbitmq node. After stopping the running node it is giving below warning? <br>
<div><br></div><div><br></div><div><div>WARN [.listener.SimpleMessageListenerContainer]: Consumer raised exception, processing can restart if the connection factory supports it</div><div>com.rabbitmq.client.ShutdownSignalException: connection error; reason: {#method<connection.close>(reply-code=541, reply-text=INTERNAL_ERROR, class-id=0, method-id=0), null, ""}</div>
<div><span class="" style="white-space:pre"> </span>at com.rabbitmq.client.impl.AMQConnection.startShutdown(AMQConnection.java:678)</div><div><span class="" style="white-space:pre"> </span>at com.rabbitmq.client.impl.AMQConnection.shutdown(AMQConnection.java:668)</div>
<div><span class="" style="white-space:pre"> </span>at com.rabbitmq.client.impl.AMQConnection.handleConnectionClose(AMQConnection.java:624)</div><div><span class="" style="white-space:pre"> </span>at com.rabbitmq.client.impl.AMQConnection.processControlCommand(AMQConnection.java:598)</div>
<div><span class="" style="white-space:pre"> </span>at com.rabbitmq.client.impl.AMQConnection$1.processAsync(AMQConnection.java:96)</div><div><span class="" style="white-space:pre"> </span>at com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:144)</div>
<div><span class="" style="white-space:pre"> </span>at com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:91)</div><div><span class="" style="white-space:pre"> </span>at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:523)</div>
<div>INFO [.listener.SimpleMessageListenerContainer]: Restarting Consumer: tag=[amq.ctag-5CJ3YJYfMZDnJOnXsds6_Q], channel=Cached Rabbit Channel: AMQChannel(amqp://<a href="http://guest@192.168.97.70:5672/,1">guest@192.168.97.70:5672/,1</a>), acknowledgeMode=AUTO local queue size=0</div>
</div><div><br></div><div>and the configuration is - </div><div><div>CachingConnectionFactory connectionFactory = new CachingConnectionFactory();</div><div><span class="" style="white-space:pre"> </span>connectionFactory.setAddresses("node1:5672,node2:5672");</div>
</div><div><br></div><div>Along with above query, I have below queries in my mind-</div><div>1> How to differenciate master and slave in rabbitmq cluster?</div><div>2> Is there any load balancer do we need ti maintain ?</div>
<div>3> How to dispatch requests to to particular node like below,</div><div> 1-100 queues => Node1</div><div> 101-200 queues => Node2</div><div> 201-300 queues => Node3, etc<br></div><div><br></div>
<div><br></div><div>Thanks in advance.</div><div><br></div><div><br></div></div>