amazon web services - RabbitMQ java client load balancing in AWS -
we using amazon elb ha rabbitmq (3.2.4) , client (java spring rabbitmq). if we've connected java client rabbit nodes it's ok. if we've used elb endpoint there new connection every ~10-60 seconds.
ps:
we using default elb idle connection timeout 60 seconds: http://docs.aws.amazon.com/elasticloadbalancing/latest/developerguide/config-idle-timeout.html
the error logs:
2016-04-19 09:14:11|thread-13|[]|error|com.reporter.message.broker.rabbit.consumer.eventprocessor:connection failed com.rabbitmq.client.alreadyclosedexception: connection closed due connection error; cause: java.io.eofexception @ com.rabbitmq.client.impl.amqchannel.processshutdownsignal(amqchannel.java:283) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.channeln.startprocessshutdownsignal(channeln.java:267) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.channeln.close(channeln.java:573) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.channeln.close(channeln.java:509) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.channeln.close(channeln.java:503) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.recovery.autorecoveringchannel.close(autorecoveringchannel.java:62) ~[amqp-client-3.5.7.jar:?] @ com.reporter.message.broker.rabbit.consumer.eventprocessor.internalreceivecycle(eventprocessor.java:89) ~[rabbit-1.1.0-cp-snapshot.jar:?] @ com.reporter.message.broker.rabbit.consumer.eventprocessor.processmessages(eventprocessor.java:50) ~[rabbit-1.1.0-cp-snapshot.jar:?] @ com.reporter.message.broker.rabbit.eventlistenerserver.lambda$startprocessing$0(eventlistenerserver.java:74) ~[rabbit-1.1.0-cp-snapshot.jar:?] @ java.lang.thread.run(thread.java:745) [?:1.8.0_72-internal] 2016-04-19 09:14:11|thread-10|[]|error|com.reporter.message.broker.rabbit.consumer.eventprocessor:connection failed com.rabbitmq.client.alreadyclosedexception: connection closed due connection error; cause: java.io.eofexception @ com.rabbitmq.client.impl.amqchannel.processshutdownsignal(amqchannel.java:283) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.channeln.startprocessshutdownsignal(channeln.java:267) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.channeln.close(channeln.java:573) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.channeln.close(channeln.java:509) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.channeln.close(channeln.java:503) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.recovery.autorecoveringchannel.close(autorecoveringchannel.java:62) ~[amqp-client-3.5.7.jar:?] @ com.reporter.message.broker.rabbit.consumer.eventprocessor.internalreceivecycle(eventprocessor.java:89) ~[rabbit-1.1.0-cp-snapshot.jar:?] @ com.reporter.message.broker.rabbit.consumer.eventprocessor.processmessages(eventprocessor.java:50) ~[rabbit-1.1.0-cp-snapshot.jar:?] @ com.reporter.message.broker.rabbit.eventlistenerserver.lambda$startprocessing$0(eventlistenerserver.java:74) ~[rabbit-1.1.0-cp-snapshot.jar:?] @ java.lang.thread.run(thread.java:745) [?:1.8.0_72-internal] 2016-04-19 09:14:11|thread-20|[]|error|com.reporter.message.broker.rabbit.consumer.eventprocessor:connection failed com.rabbitmq.client.alreadyclosedexception: connection closed due connection error; cause: java.io.eofexception @ com.rabbitmq.client.impl.amqchannel.processshutdownsignal(amqchannel.java:283) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.channeln.startprocessshutdownsignal(channeln.java:267) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.channeln.close(channeln.java:573) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.channeln.close(channeln.java:509) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.channeln.close(channeln.java:503) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.recovery.autorecoveringchannel.close(autorecoveringchannel.java:62) ~[amqp-client-3.5.7.jar:?] @ com.reporter.message.broker.rabbit.consumer.eventprocessor.internalreceivecycle(eventprocessor.java:89) ~[rabbit-1.1.0-cp-snapshot.jar:?] @ com.reporter.message.broker.rabbit.consumer.eventprocessor.processmessages(eventprocessor.java:50) ~[rabbit-1.1.0-cp-snapshot.jar:?] @ com.reporter.message.broker.rabbit.eventlistenerserver.lambda$startprocessing$0(eventlistenerserver.java:74) ~[rabbit-1.1.0-cp-snapshot.jar:?] @ java.lang.thread.run(thread.java:745) [?:1.8.0_72-internal] 2016-04-19 09:14:11|thread-17|[]|error|com.reporter.message.broker.rabbit.consumer.eventprocessor:connection failed com.rabbitmq.client.alreadyclosedexception: connection closed due connection error; cause: java.io.eofexception @ com.rabbitmq.client.impl.amqchannel.processshutdownsignal(amqchannel.java:283) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.channeln.startprocessshutdownsignal(channeln.java:267) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.channeln.close(channeln.java:573) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.channeln.close(channeln.java:509) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.channeln.close(channeln.java:503) ~[amqp-client-3.5.7.jar:?] @ com.rabbitmq.client.impl.recovery.autorecoveringchannel.close(autorecoveringchannel.java:62) ~[amqp-client-3.5.7.jar:?] @ com.reporter.message.broker.rabbit.consumer.eventprocessor.internalreceivecycle(eventprocessor.java:89) ~[rabbit-1.1.0-cp-snapshot.jar:?] @ com.reporter.message.broker.rabbit.consumer.eventprocessor.processmessages(eventprocessor.java:50) ~[rabbit-1.1.0-cp-snapshot.jar:?] @ com.reporter.message.broker.rabbit.eventlistenerserver.lambda$startprocessing$0(eventlistenerserver.java:74) ~[rabbit-1.1.0-cp-snapshot.jar:?] @ java.lang.thread.run(thread.java:745) [?:1.8.0_72-internal]
Comments
Post a Comment