<div dir="ltr"><div><div><div>Hello,<br><br></div>I am using rabbit mq cluster. My consumer is connected this cluster via haproxy.<br><br></div>Consumer raised the following exception connected through the haproxy. If consumer directly connected to the node will not raise any exceptions.<br>
<br>2013-01-08 16:25:09,745  WARN | SimpleAsyncTaskExecutor-1 | o.s.amqp.rabbit.listener.SimpleMessageListenerContainer | Consumer raised exception, processing can restart if the connection factory supports it. Exception summary: com.rabbitmq.client.ShutdownSignalException: connection error; reason: java.io.EOFException<br>
<br></div>See my ha-proxy configuration.<br><br>global<br>��� log 127.0.0.1��� local0<br>��� log 127.0.0.1��� local1 notice<br>��� #log loghost��� local0 info<br>��� maxconn 4096<br>��� #chroot /usr/share/haproxy<br>��� user haproxy<br>
��� group haproxy<br>��� daemon<br>��� #debug<br>��� #quiet<br><br>defaults<br>��� log��� global<br>#��� mode��� http<br>#��� option��� httplog<br>��� option��� dontlognull<br>��� retries��� 3<br>��� option redispatch<br>
��� maxconn��� 5000<br>��� contimeout��� 10000<br>��� clitimeout��� 60000<br>��� srvtimeout��� 60000<br><br><br>listen rabbitmq_producer_cluster <a href="http://0.0.0.0:5672">0.0.0.0:5672</a><br>��� mode tcp������������������������������������������������ <br>
��� balance roundrobin����������������� <br>����������������������������������������������������������������� <br>��� server rabbit_1 rabbit1:5672 check inter 5000 rise 2 fall 3���� <br>��� server rabbit_2 rabbit2:5672 check inter 5000 rise 2 fall 3<br>
��� #server rabbit_3 rabbit3:5672 check inter 5000 rise 2 fall 3<br><br>listen rabbitmq_consumer_cluster <a href="http://0.0.0.0:5673">0.0.0.0:5673</a><br>��� mode tcp<br>��� balance roundrobin<br>��� option tcpka��� <br>
<br>��� server rabbit_1 rabbit1:5672 check inter 5000 rise 2 fall 3<br>��� server rabbit_2 rabbit2:5672 backup check inter 5000 rise 2 fall 3<br>��� #server rabbit_3 rabbit3:5672 check inter 5000 rise 2 fall 3<br><br>listen private_monitoring :8100<br>
��� mode http<br>��� option httplog<br>��� stats enable<br>��� stats uri�� /stats<br>��� stats refresh 5s<br><br></div>