You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by janylj <ja...@gmail.com> on 2008/09/08 23:35:27 UTC
Cannot unsubscribe the durable subscriber because of
InvalidClientIDException
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.
Re: Cannot unsubscribe the durable subscriber because of
InvalidClientIDException
Posted by janylj <ja...@gmail.com>.
I am confused here. Because the error didn't happen when creating the durable
subscriber. It happened when unsubscribe the durable subscriber. I image
there is of course an existing connection with clientID of "TestClient",
which is exactly the durable subscriber I want to unsubscribe.
Also the error didn't happen when unsubscribing the first durable
subscriber. And as my sequence shows, after the first unsubscribe(), the
Admin console said the number of consumers of this topic is 0.
startSubscriberSeparately();
unsubscribe();
//Inspect Admin console, number of consumers for this topic is 0.
Thread.sleep(5000);
startSubscriberSeparately();
unsubscribe();
Thank you.
Joe Fernandez wrote:
>
> Looks to me like you're trying to establish two connections with the same
> same clientid (TestClient), which is not allowed.
>
> Joe
> Get a free ActiveMQ user guide @ http://www.ttmsolutions.com
>
>
>
> janylj wrote:
>>
>> 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-tp19381769p19396299.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Cannot unsubscribe the durable subscriber because of
InvalidClientIDException
Posted by Joe Fernandez <jo...@ttmsolutions.com>.
Looks to me like you're trying to establish two connections with the same
same clientid (TestClient), which is not allowed.
Joe
Get a free ActiveMQ user guide @ http://www.ttmsolutions.com
janylj wrote:
>
> 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-tp19381769p19390459.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.