<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>