activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "James Strachan" <james.strac...@gmail.com>
Subject Re: Exception on Durable Consumer
Date Sun, 16 Apr 2006 16:41:19 GMT
BTW which version of ActiveMQ are you using?
Are you purely using a single durable topic subscriber?

James

On 4/15/06, ssarkar <ssarkar@reconnex.net> wrote:
>
> Hello,
>
> I am using persistent transmission through ActiveMQ.  I am getting some jms
> exception for durable consumer being used as follows ::
>
> 2006-04-13 16:11:53,928 DEBUG
> [org.apache.activemq.broker.region.AbstractRegion] Adding destination:
> topic://topic.ETLResponseTopic-ig2im
> 2006-04-13 16:11:53,930 INFO  [STDOUT] In the annotation delete cycle with
> DELETE_ANNOTATION_CYCLE_IN_SECONDS= 86400
> 2006-04-13 16:11:53,938 INFO
> [org.apache.activemq.broker.AbstractConnection.Service] Async error
> occurred: javax.jms.JMSException: Durable consumer is in use for client:
> NC_hub_inboundimanager and subscriptionName: imanager
> javax.jms.JMSException: Durable consumer is in use for client:
> NC_hub_inboundimanager and subscriptionName: imanager
>         at
> org.apache.activemq.broker.region.TopicRegion.addConsumer(TopicRegion.java:76)
>         at
> org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:261)
>         at
> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:68)
>         at
> org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:75)
>         at
> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:68)
>         at
> org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:80)
>         at
> org.apache.activemq.broker.AbstractConnection.processAddConsumer(AbstractConnection.java:422)
>         at
> org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:291)
>         at
> org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:196)
>         at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
>         at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:88)
>         at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:70)
>         at
> org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:75)
>         at
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
>         at
> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:55)
>         at
> org.apache.activemq.network.DemandForwardingBridgeSupport.addSubscription(DemandForwardingBridgeSupport.java:337)
>         at
> org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteConsumerAdvisory(DemandForwardingBridgeSupport.java:316)
>         at
> org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteCommand(DemandForwardingBridgeSupport.java:267)
>         at
> org.apache.activemq.network.DemandForwardingBridgeSupport$2.onCommand(DemandForwardingBridgeSupport.java:117)
>         at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:88)
>         at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:70)
>         at
> org.apache.activemq.transport.failover.FailoverTransport$1.onCommand(FailoverTransport.java:103)
>         at
> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
>         at
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
>         at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
>         at java.lang.Thread.run(Thread.java:595)
>
>
> What can I do to get rid of this exception ?
>
> Thanks,
> Shyam Sarkar
> ssarkar@reconnex.net
> 650-940-4152
>
> --
> View this message in context: http://www.nabble.com/Exception-on-Durable-Consumer-t1452032.html#a3923980
> Sent from the ActiveMQ - Dev forum at Nabble.com.
>
>


--

James
-------
http://radio.weblogs.com/0112098/

Mime
View raw message