[rabbitmq-discuss] RabbitMQ clustering issue - exception while stopping the running node

[Rajasekhar P]

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?


WARN  [.listener.SimpleMessageListenerContainer]: Consumer raised
exception, processing can restart if the connection factory supports it
com.rabbitmq.client.ShutdownSignalException: connection error; reason:
{#method<connection.close>(reply-code=541, reply-text=INTERNAL_ERROR,
class-id=0, method-id=0), null, ""}
at
com.rabbitmq.client.impl.AMQConnection.startShutdown(AMQConnection.java:678)
at com.rabbitmq.client.impl.AMQConnection.shutdown(AMQConnection.java:668)
at
com.rabbitmq.client.impl.AMQConnection.handleConnectionClose(AMQConnection.java:624)
at
com.rabbitmq.client.impl.AMQConnection.processControlCommand(AMQConnection.java:598)
at
com.rabbitmq.client.impl.AMQConnection$1.processAsync(AMQConnection.java:96)
at
com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:144)
at com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:91)
at
com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:523)
INFO  [.listener.SimpleMessageListenerContainer]: Restarting Consumer:
tag=[amq.ctag-5CJ3YJYfMZDnJOnXsds6_Q], channel=Cached Rabbit Channel:
AMQChannel(amqp://guest@192.168.97.70:5672/,1), acknowledgeMode=AUTO local
queue size=0

and the configuration is -
CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
connectionFactory.setAddresses("node1:5672,node2:5672");

Along with above query, I have below queries in my mind-
1> How to differenciate master and slave in rabbitmq cluster?
2> Is there any load balancer do we need ti maintain ?
3> How to dispatch requests to to particular node like below,
      1-100 queues => Node1
     101-200 queues => Node2
     201-300 queues => Node3, etc


Thanks in advance.
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20131007/8e69cbee/attachment.htm>