You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by James Green <ja...@gmail.com> on 2012/10/26 12:42:43 UTC

Async Errors and duplex bridges

I'm seeing the following, repeatedly, in our logs (5.7.0):

2012-10-26 11:37:04,193 | WARN  | Async error occurred:
javax.jms.JMSException: Durable consumer is in use for client: hub_zorin_i
nbound_hub and subscriptionName: quarrel-server_requests |
org.apache.activemq.broker.TransportConnection.Service | ActiveMQ Trans
port: ssl:///x.x.x.x:35554
javax.jms.JMSException: Durable consumer is in use for client:
hub_zorin_inbound_hub and subscriptionName: quarrel-server_requests
        at
org.apache.activemq.broker.region.TopicRegion.addConsumer(TopicRegion.java:122)
        at
org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:421)
        at
org.apache.activemq.broker.jmx.ManagedRegionBroker.addConsumer(ManagedRegionBroker.java:257)
        at
org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89)
        at
org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:92)
        at
org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89)
        at
org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89)
        at
org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:95)
        at
org.apache.activemq.broker.TransportConnection.processAddConsumer(TransportConnection.java:562)
        at
org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:332)
        at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294)
        at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:152)
        at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
        at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
        at
org.apache.activemq.transport.vm.VMTransport.doDispatch(VMTransport.java:138)
        at
org.apache.activemq.transport.vm.VMTransport.dispatch(VMTransport.java:127)
        at
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:104)
        at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)
        at
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
        at
org.apache.activemq.network.DemandForwardingBridgeSupport.addSubscription(DemandForwardingBridgeSupport.java:649)
        at
org.apache.activemq.network.DemandForwardingBridgeSupport.addConsumerInfo(DemandForwardingBridgeSupport.java:1001)
        at
org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteConsumerAdvisory(DemandForwardingBridgeSupport.java:586)
        at
org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteCommand(DemandForwardingBridgeSupport.java:457)
        at
org.apache.activemq.network.DemandForwardingBridgeSupport$2.onCommand(DemandForwardingBridgeSupport.java:179)
        at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
        at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
        at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
        at
org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:256)
        at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
        at
org.apache.activemq.transport.tcp.SslTransport.doConsume(SslTransport.java:91)
        at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:222)
        at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:204)
        at java.lang.Thread.run(Thread.java:679)
2012-10-26 11:37:05,214 | INFO  | Network connection between vm://hub#10
and ssl://x.x.x.x/x.x.x.x:35554 shutdown due to a local error:
javax.jms.JMSException: Durable consumer is in use for client:
hub_zorin_inbound_hub and subscriptionName: quarrel-server_requests |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
BrokerService[hub] Task-61
2012-10-26 11:37:05,215 | WARN  | failed to deliver remove command for
local subscription, for remote ID:quarrel-48626-1351182113439-4:188952:-1:1
| org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
BrokerService[hub] Task-64
org.apache.activemq.transport.TransportDisposedIOException: Peer
(vm://hub#11) disposed.

Our topology has our hub in our office connected via ADSL to three remote
brokers each of which have various services on them. Each isolated broker
has PHP scripts connecting via PECL Stomp.

I'm wondering if there might be a timing problem due to temporary bandwidth
restrictions perhaps? Pure speculation as I have little else to go by...

Thanks,

James