activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From brucent <bruc...@gmail.com>
Subject Re: AMQ 5.5.1 - Message Routing Doesn't Resume After Network Outage
Date Thu, 29 Mar 2012 22:50:22 GMT
A bit more info after a bit of investigation...  It appears that Network
Connector is created, but not active.  When it works, I see this in the log:

[org.apache.activemq.transport.failover.FailoverTransport] : Connection
established
[org.apache.activemq.transport.failover.FailoverTransport] : Successfully
reconnected to tcp://localhost:63001

but when the queue's subscription is not created, FailoverTransport just
reports the establishment of the connection  not that it as successfully
connected:

[org.apache.activemq.transport.failover.FailoverTransport] : Connection
established

Stopping the process in a debugger, I see that the thread appears to stuck
DemainFtransportListener.transportResumed() call in FailoverTransport.

org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1281)
org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:830)
org.apache.activemq.broker.TransportConnection.dispatchSync(TransportConnection.java:790)
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:183)
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
org.apache.activemq.transport.vm.VMTransport.dispatch(VMTransport.java:121)
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:112)
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81)
org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:86)
org.apache.activemq.network.DemandForwardingBridgeSupport.startLocalBridge(DemandForwardingBridgeSupport.java:297)
org.apache.activemq.network.DemandForwardingBridgeSupport$2.transportResumed(DemandForwardingBridgeSupport.java:214)
org.apache.activemq.transport.TransportFilter.transportResumed(TransportFilter.java:109)
org.apache.activemq.transport.TransportFilter.transportResumed(TransportFilter.java:109)
org.apache.activemq.transport.failover.FailoverTransport.doReconnect(FailoverTransport.java:885)
org.apache.activemq.transport.failover.FailoverTransport$2.iterate(FailoverTransport.java:136)
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
java.lang.Thread.run(Thread.java:619)


--
View this message in context: http://activemq.2283324.n4.nabble.com/AMQ-5-5-1-Message-Routing-Doesn-t-Resume-After-Network-Outage-tp4516807p4517307.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message