BTW which version of ActiveMQ are you using? Are you purely using a single durable topic subscriber?
James On 4/15/06, ssarkar <[EMAIL PROTECTED]> 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 > [EMAIL PROTECTED] > 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/
