You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by khandelwalanuj <kh...@gmail.com> on 2014/12/22 13:58:17 UTC
After broker restart, subscirber is not able to connect
Hi,
Using ActiveMQ-5.10.
After restarting the broker, the client does not seem to be able to recover
and forever spits out. Clients throws
[ 2014-12-18 18:17:58,852 [StatsCollector-3]
jmx.TCAQueueSizeMonitor.getPendingQueueSize():68 ERROR]: Exception while
getting TCA queue size status!!!
**javax.jms.IllegalStateException: The Session is closed**
at
org.apache.activemq.ActiveMQSession.checkClosed(ActiveMQSession.java:767)
at
org.apache.activemq.ActiveMQSession.createBrowser(ActiveMQSession.java:1425)
at
org.apache.activemq.jms.pool.PooledSession.createBrowser(PooledSession.java:294)
at
deshaw.moss.jmx.TCAQueueSizeMonitor.getPendingQueueSize(TCAQueueSizeMonitor.java:63)
at
deshaw.moss.jmx.TCAQueueSizeMonitor.getTCAQueueSizeStatus(TCAQueueSizeMonitor.java:101)
at
deshaw.moss.jmx.TCAHeartBeatStatsCollector.run(TCAHeartBeatStatsCollector.java:60)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
The Session is closed once and then after it below exception continuously
comes:
[ 2014-12-19 00:00:06,176 [securityEventDataSubscriberContainer-4105]
listener.DefaultMessageListenerContainer.handleListenerSetupFailure():842
WARN ]: Setup of JMS message listener invoker failed for destination
'topic://check.newSecurityPublish' - trying to recover. Cause:
org.apache.activemq.ConnectionFailedException: The JMS connection has
failed: Connection refused
[ 2014-12-19 00:00:06,476 [securityEventDataSubscriberContainer-4105]
listener.DefaultMessageListenerContainer.refreshConnectionUntilSuccessful():891
INFO ]: Successfully refreshed JMS Connection
Please note that we are seeing this only for one client and that too
sometimes. Other clients are able communicate with the broker properly.
Client is using pooledConnection factory to create the connection.
Thanks,
Anuj
--
View this message in context: http://activemq.2283324.n4.nabble.com/After-broker-restart-subscirber-is-not-able-to-connect-tp4689171.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
Re: After broker restart, subscriber is not able to connect forever
Posted by xabhi <xa...@gmail.com>.
I also saw a similar problem where my listener is not able to connect to
broker if it gets restarted. I have some debug logs if it helps:
[20141223 01:21:39.277 EST (ActiveMQ Task-3)
org.apache.activemq.transport.failover.FailoverTransport#doReconnect 1089
ERROR] - Failed to connect to [tcp://a
rgon47.nyc:61616?wireFormat.maxInactivityDuration=120000,
tcp://argon36.nyc:61616?wireFormat.maxInactivityDuration=120000] after: 5
attempt(s)
[20141223 01:21:39.277 EST (ActiveMQ Task-3)
org.apache.activemq.ActiveMQConnection#onAsyncException 2010 DEBUG] - Async
exception with no exception listener
: java.net.ConnectException: Connection refused
java.net.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method)
at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:345)
at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at
org.apache.activemq.transport.tcp.TcpTransport.connect(TcpTransport.java:501)
at
org.apache.activemq.transport.tcp.TcpTransport.doStart(TcpTransport.java:464)
at
org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:55)
at
org.apache.activemq.transport.AbstractInactivityMonitor.start(AbstractInactivityMonitor.java:138)
at
org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58)
at
org.apache.activemq.transport.WireFormatNegotiator.start(WireFormatNegotiator.java:72)
at
org.apache.activemq.transport.failover.FailoverTransport.doReconnect(FailoverTransport.java:1017)
at
org.apache.activemq.transport.failover.FailoverTransport$2.iterate(FailoverTransport.java:148)
at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)
at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
[20141223 01:21:39.279 EST (ActiveMQ Connection Executor: unconnected)
org.apache.activemq.transport.failover.FailoverTransport#stop 366 DEBUG] -
Stopped unc
onnected
[20141223 01:21:39.279 EST (ActiveMQ Connection Executor: unconnected)
org.apache.activemq.util.ThreadPoolUtils#shutdownNow 54 DEBUG] - Forcing
shutdown of E
xecutorService: java.util.concurrent.ThreadPoolExecutor@31736876[Running,
pool size = 2, active threads = 0, queued tasks = 0, completed tasks = 5]
[20141223 01:21:39.281 EST (ActiveMQ Connection Executor: unconnected)
org.apache.activemq.pool.PooledConnectionFactory$1$1#onException 110 INFO] -
Expiring connection ActiveMQConnection
{id=ID:cobalt14-49500-1419315471791-1:1,clientId=ID:cobalt14-49500-1419315471791-0:1,started=false}
on IOException: java.net.ConnectException: Connection refused
[20141223 01:21:39.281 EST (ActiveMQ Connection Executor: unconnected)
org.apache.activemq.pool.PooledConnectionFactory$1$1#onException 111 DEBUG]
- Expiring connection on IOException
java.net.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method)
at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:345)
at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at
org.apache.activemq.transport.tcp.TcpTransport.connect(TcpTransport.java:501)
at
org.apache.activemq.transport.tcp.TcpTransport.doStart(TcpTransport.java:464)
at
org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:55)
at
org.apache.activemq.transport.AbstractInactivityMonitor.start(AbstractInactivityMonitor.java:138)
at
org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58)
at
org.apache.activemq.transport.WireFormatNegotiator.start(WireFormatNegotiator.java:72)
at
org.apache.activemq.transport.failover.FailoverTransport.doReconnect(FailoverTransport.java:1017)
at
org.apache.activemq.transport.failover.FailoverTransport$2.iterate(FailoverTransport.java:148)
at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)
at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
[20141223 01:21:39.282 EST (jmsContainer2-1)
org.apache.activemq.jms.pool.PooledSession#close 119 WARN] - Caught
exception trying rollback() when putting session back into the pool, will
invalidate. javax.jms.IllegalStateException: The Session is closed
javax.jms.IllegalStateException: The Session is closed
at
org.apache.activemq.ActiveMQSession.checkClosed(ActiveMQSession.java:767)
at
org.apache.activemq.ActiveMQSession.rollback(ActiveMQSession.java:588)
at
org.apache.activemq.jms.pool.PooledSession.close(PooledSession.java:116)
at
org.springframework.jms.support.JmsUtils.closeSession(JmsUtils.java:108)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.clearResources(DefaultMessageListenerContainer.java:1143)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:1002)
at java.lang.Thread.run(Thread.java:745)
[20141223 01:21:39.282 EST (jmsContainer1-1)
org.apache.activemq.jms.pool.PooledSession#close 119 WARN] - Caught
exception trying rollback() when putting session back into the pool, will
invalidate. javax.jms.IllegalStateException: The Session is closed
javax.jms.IllegalStateException: The Session is closed
at
org.apache.activemq.ActiveMQSession.checkClosed(ActiveMQSession.java:767)
at
org.apache.activemq.ActiveMQSession.rollback(ActiveMQSession.java:588)
at
org.apache.activemq.jms.pool.PooledSession.close(PooledSession.java:116)
at
org.springframework.jms.support.JmsUtils.closeSession(JmsUtils.java:108)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.clearResources(DefaultMessageListenerContainer.java:1143)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:1002)
at java.lang.Thread.run(Thread.java:745)
[20141223 01:21:39.283 EST (jmsContainer2-1)
org.springframework.jms.listener.DefaultMessageListenerContainer#handleListenerSetupFailure
839 WARN] - Setup of JMS message listener invoker failed for destination
'topic://test.topic' - trying to recover. Cause: Connection refused
javax.jms.JMSException: Connection refused
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:72)
at
org.apache.activemq.ActiveMQMessageConsumer.dequeue(ActiveMQMessageConsumer.java:484)
at
org.apache.activemq.ActiveMQMessageConsumer.receive(ActiveMQMessageConsumer.java:631)
at
org.apache.activemq.jms.pool.PooledMessageConsumer.receive(PooledMessageConsumer.java:67)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveMessage(AbstractPollingMessageListenerContainer.java:430)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:310)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1102)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1094)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:991)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.net.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method)
at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:345)
at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at
org.apache.activemq.transport.tcp.TcpTransport.connect(TcpTransport.java:501)
at
org.apache.activemq.transport.tcp.TcpTransport.doStart(TcpTransport.java:464)
at
org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:55)
at
org.apache.activemq.transport.AbstractInactivityMonitor.start(AbstractInactivityMonitor.java:138)
at
org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58)
at
org.apache.activemq.transport.WireFormatNegotiator.start(WireFormatNegotiator.java:72)
at
org.apache.activemq.transport.failover.FailoverTransport.doReconnect(FailoverTransport.java:1017)
at
org.apache.activemq.transport.failover.FailoverTransport$2.iterate(FailoverTransport.java:148)
at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)
at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
... 1 more
[20141223 01:21:39.283 EST (jmsContainer1-1)
org.springframework.jms.listener.DefaultMessageListenerContainer#handleListenerSetupFailure
839 WARN] - Setup of JMS message listener invoker failed for destination
'topic://test.topic' - trying to recover. Cause: Connection refused
javax.jms.JMSException: Connection refused
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:72)
at
org.apache.activemq.ActiveMQMessageConsumer.dequeue(ActiveMQMessageConsumer.java:484)
at
org.apache.activemq.ActiveMQMessageConsumer.receive(ActiveMQMessageConsumer.java:631)
at
org.apache.activemq.jms.pool.PooledMessageConsumer.receive(PooledMessageConsumer.java:67)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveMessage(AbstractPollingMessageListenerContainer.java:430)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:310)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1102)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1094)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:991)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.net.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method)
at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:345)
at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at
org.apache.activemq.transport.tcp.TcpTransport.connect(TcpTransport.java:501)
at
org.apache.activemq.transport.tcp.TcpTransport.doStart(TcpTransport.java:464)
at
org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:55)
at
org.apache.activemq.transport.AbstractInactivityMonitor.start(AbstractInactivityMonitor.java:138)
at
org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58)
at
org.apache.activemq.transport.WireFormatNegotiator.start(WireFormatNegotiator.java:72)
at
org.apache.activemq.transport.failover.FailoverTransport.doReconnect(FailoverTransport.java:1017)
at
org.apache.activemq.transport.failover.FailoverTransport$2.iterate(FailoverTransport.java:148)
at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)
at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
... 1 more
[20141223 01:21:39.284 EST (jmsContainer2-1)
org.springframework.jms.listener.DefaultMessageListenerContainer#refreshConnectionUntilSuccessful
891 INFO] - Successfully refreshed JMS Connection
[20141223 01:21:39.284 EST (jmsContainer1-1)
org.springframework.jms.listener.DefaultMessageListenerContainer#refreshConnectionUntilSuccessful
891 INFO] - Successfully refreshed JMS Connection
[20141223 01:21:44.286 EST (jmsContainer1-2)
org.springframework.jms.listener.DefaultMessageListenerContainer#handleListenerSetupFailure
839 WARN] - Setup of JMS message listener invoker failed for destination
'topic://test.topic' - trying to recover. Cause:
org.apache.activemq.ConnectionFailedException: The JMS connection has
failed: Connection refused
javax.jms.IllegalStateException:
org.apache.activemq.ConnectionFailedException: The JMS connection has
failed: Connection refused
at
org.apache.activemq.jms.pool.ConnectionPool.createSession(ConnectionPool.java:135)
at
org.apache.activemq.jms.pool.PooledConnection.createSession(PooledConnection.java:167)
at
org.springframework.jms.support.JmsAccessor.createSession(JmsAccessor.java:197)
at
org.springframework.jms.listener.DefaultMessageListenerContainer.access$1400(DefaultMessageListenerContainer.java:119)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.initResourcesIfNecessary(DefaultMessageListenerContainer.java:1122)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1101)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1094)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:991)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.activemq.ConnectionFailedException: The JMS connection
has failed: Connection refused
at
org.apache.activemq.ActiveMQConnection.checkClosedOrFailed(ActiveMQConnection.java:1492)
at
org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:327)
at
org.apache.activemq.jms.pool.ConnectionPool.makeSession(ConnectionPool.java:104)
at
org.apache.activemq.jms.pool.ConnectionPool$1.makeObject(ConnectionPool.java:81)
at
org.apache.activemq.jms.pool.ConnectionPool$1.makeObject(ConnectionPool.java:66)
at
org.apache.commons.pool.impl.GenericKeyedObjectPool.borrowObject(GenericKeyedObjectPool.java:1220)
at
org.apache.activemq.jms.pool.ConnectionPool.createSession(ConnectionPool.java:133)
... 8 more
Caused by: java.net.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method)
at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:345)
at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at
org.apache.activemq.transport.tcp.TcpTransport.connect(TcpTransport.java:501)
at
org.apache.activemq.transport.tcp.TcpTransport.doStart(TcpTransport.java:464)
at
org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:55)
at
org.apache.activemq.transport.AbstractInactivityMonitor.start(AbstractInactivityMonitor.java:138)
at
org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58)
at
org.apache.activemq.transport.WireFormatNegotiator.start(WireFormatNegotiator.java:72)
at
org.apache.activemq.transport.failover.FailoverTransport.doReconnect(FailoverTransport.java:1017)
at
org.apache.activemq.transport.failover.FailoverTransport$2.iterate(FailoverTransport.java:148)
at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)
at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
... 1 more
[20141223 01:21:44.286 EST (jmsContainer2-2)
org.springframework.jms.listener.DefaultMessageListenerContainer#handleListenerSetupFailure
839 WARN] - Setup of JMS message listener invoker failed for destination
'topic://test.topic' - trying to recover. Cause:
org.apache.activemq.ConnectionFailedException: The JMS connection has
failed: Connection refused
javax.jms.IllegalStateException:
org.apache.activemq.ConnectionFailedException: The JMS connection has
failed: Connection refused
at
org.apache.activemq.jms.pool.ConnectionPool.createSession(ConnectionPool.java:135)
at
org.apache.activemq.jms.pool.PooledConnection.createSession(PooledConnection.java:167)
at
org.springframework.jms.support.JmsAccessor.createSession(JmsAccessor.java:197)
at
org.springframework.jms.listener.DefaultMessageListenerContainer.access$1400(DefaultMessageListenerContainer.java:119)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.initResourcesIfNecessary(DefaultMessageListenerContainer.java:1122)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1101)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1094)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:991)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.activemq.ConnectionFailedException: The JMS connection
has failed: Connection refused
at
org.apache.activemq.ActiveMQConnection.checkClosedOrFailed(ActiveMQConnection.java:1492)
at
org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:327)
at
org.apache.activemq.jms.pool.ConnectionPool.makeSession(ConnectionPool.java:104)
at
org.apache.activemq.jms.pool.ConnectionPool$1.makeObject(ConnectionPool.java:81)
at
org.apache.activemq.jms.pool.ConnectionPool$1.makeObject(ConnectionPool.java:66)
at
org.apache.commons.pool.impl.GenericKeyedObjectPool.borrowObject(GenericKeyedObjectPool.java:1220)
at
org.apache.activemq.jms.pool.ConnectionPool.createSession(ConnectionPool.java:133)
... 8 more
Caused by: java.net.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method)
at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:345)
at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at
org.apache.activemq.transport.tcp.TcpTransport.connect(TcpTransport.java:501)
at
org.apache.activemq.transport.tcp.TcpTransport.doStart(TcpTransport.java:464)
at
org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:55)
at
org.apache.activemq.transport.AbstractInactivityMonitor.start(AbstractInactivityMonitor.java:138)
at
org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58)
at
org.apache.activemq.transport.WireFormatNegotiator.start(WireFormatNegotiator.java:72)
at
org.apache.activemq.transport.failover.FailoverTransport.doReconnect(FailoverTransport.java:1017)
at
org.apache.activemq.transport.failover.FailoverTransport$2.iterate(FailoverTransport.java:148)
at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)
at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
... 1 more
[20141223 01:21:44.288 EST (jmsContainer1-2)
org.springframework.jms.listener.DefaultMessageListenerContainer#refreshConnectionUntilSuccessful
891 INFO] - Successfully refreshed JMS Connection
[20141223 01:21:44.289 EST (jmsContainer2-2)
org.springframework.jms.listener.DefaultMessageListenerContainer#refreshConnectionUntilSuccessful
891 INFO] - Successfully refreshed JMS Connection
[20141223 01:21:49.291 EST (jmsContainer2-3)
org.springframework.jms.listener.DefaultMessageListenerContainer#handleListenerSetupFailure
839 WARN] - Setup of JMS message listener invoker failed for destination
'topic://test.topic' - trying to recover. Cause:
org.apache.activemq.ConnectionFailedException: The JMS connection has
failed: Connection refused
javax.jms.IllegalStateException:
org.apache.activemq.ConnectionFailedException: The JMS connection has
failed: Connection refused
at
org.apache.activemq.jms.pool.ConnectionPool.createSession(ConnectionPool.java:135)
at
org.apache.activemq.jms.pool.PooledConnection.createSession(PooledConnection.java:167)
at
org.springframework.jms.support.JmsAccessor.createSession(JmsAccessor.java:197)
at
org.springframework.jms.listener.DefaultMessageListenerContainer.access$1400(DefaultMessageListenerContainer.java:119)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.initResourcesIfNecessary(DefaultMessageListenerContainer.java:1122)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1101)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1094)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:991)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.activemq.ConnectionFailedException: The JMS connection
has failed: Connection refused
at
org.apache.activemq.ActiveMQConnection.checkClosedOrFailed(ActiveMQConnection.java:1492)
at
org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:327)
at
org.apache.activemq.jms.pool.ConnectionPool.makeSession(ConnectionPool.java:104)
at
org.apache.activemq.jms.pool.ConnectionPool$1.makeObject(ConnectionPool.java:81)
at
org.apache.activemq.jms.pool.ConnectionPool$1.makeObject(ConnectionPool.java:66)
at
org.apache.commons.pool.impl.GenericKeyedObjectPool.borrowObject(GenericKeyedObjectPool.java:1220)
at
org.apache.activemq.jms.pool.ConnectionPool.createSession(ConnectionPool.java:133)
... 8 more
Caused by: java.net.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method)
at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:345)
at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at
org.apache.activemq.transport.tcp.TcpTransport.connect(TcpTransport.java:501)
at
org.apache.activemq.transport.tcp.TcpTransport.doStart(TcpTransport.java:464)
at
org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:55)
at
org.apache.activemq.transport.AbstractInactivityMonitor.start(AbstractInactivityMonitor.java:138)
at
org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58)
at
org.apache.activemq.transport.WireFormatNegotiator.start(WireFormatNegotiator.java:72)
at
org.apache.activemq.transport.failover.FailoverTransport.doReconnect(FailoverTransport.java:1017)
at
org.apache.activemq.transport.failover.FailoverTransport$2.iterate(FailoverTransport.java:148)
at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)
at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
... 1 more
Thanks,
Abhi
--
View this message in context: http://activemq.2283324.n4.nabble.com/After-broker-restart-subscriber-is-not-able-to-connect-forever-tp4689171p4689205.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
Re: After broker restart, subscriber is not able to connect forever
Posted by bansalp <bp...@gmail.com>.
I am facing same issue.
ActiveMQ gods could you please help.
--
View this message in context: http://activemq.2283324.n4.nabble.com/After-broker-restart-subscriber-is-not-able-to-connect-forever-tp4689171p4689175.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.