activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From janylj <jan...@gmail.com>
Subject Cannot unsubscribe the durable subscriber because of InvalidClientIDException
Date Mon, 08 Sep 2008 21:35:27 GMT

Hello,

I have the following test on the durable subscriber using ActiveMQ 5.1,
which creating a durable subscriber and then unsubscribe it. Then create
another durable subscriber using the same ClientID and durable subscription
name as the the first one and unsubscribe it.

startSubscriberSeparately();
unsubscribe();
//Inspect Admin console, number of consumers for this topic is 0.
Thread.sleep(5000);
startSubscriberSeparately();			
unsubscribe();

The second unsubscribe fails because of:
Caused by: javax.jms.InvalidClientIDException: Broker: localhost - Client:
TestClient already connected from /127.0.0.1:44209
	at
org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:211)
	at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:81)
	at
org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:75)
	at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:81)
	at
org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:88)
	at
org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:662)
	at
org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:86)
	at
org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:125)
	at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292)
	at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:180)
	at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
	at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:143)
	at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:206)
	at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
	at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:196)
	at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:183)
	at java.lang.Thread.run(Thread.java:595)

Any input? Thank you very much.

-- 
View this message in context: http://www.nabble.com/Cannot-unsubscribe-the-durable-subscriber-because-of-InvalidClientIDException-tp19381769p19381769.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message