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.
