activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aleksandar Ivanisevic <aleksan...@ivanisevic.de>
Subject Re: STOMP and durable topic subscriptions
Date Fri, 27 May 2011 14:40:38 GMT
Dejan Bosanac <dejan@nighttale.net> writes:

> Take a look at StompTest.testDurableUnsub()
>
> https://fisheye6.atlassian.com/browse/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java?hb=true
>
>
> It contains some example that should work. If it's not working, can you
> please provide a similar test case
> <https://fisheye6.atlassian.com/browse/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java?hb=true>
> Regards


How sure are you that that test actually passes? I've just done
basically the same thing and I get the exception


[support@2elogger-test ~]$ telnet adminbroker-test 61613
Trying 192.168.222.78...
Connected to adminbroker-test.
Escape character is '^]'.
CONNECT  
client-id:adminbroker-test
passcode:xxx
login:xxx

^@
CONNECTED
session:adminbroker-test


SUBSCRIBE
activemq.prefetchSize:5
activemq.subscriptionName:masterbcast
ack:auto
destination:/topic/COMMAND.broadcast

^@

DISCONNECT
client-id:adminbroker-test

^@
Connection closed by foreign host.
[support@2elogger-test ~]$ telnet adminbroker-test 61613
Trying 192.168.222.78...
Connected to adminbroker-test.
Escape character is '^]'.
CONNECT  
client-id:adminbroker-test
passcode:xxx
login:xxx

^@
CONNECTED
session:adminbroker-test


UNSUBSCRIBE
destination:/topic/COMMAND.broadcast
ack:auto
activemq.subscriptionName:masterbcast

^@
ERROR
message:No durable subscription exists for: masterbcast

javax.jms.InvalidDestinationException: No durable subscription exists for: masterbcast
	at org.apache.activemq.broker.region.TopicRegion.removeSubscription(TopicRegion.java:135)
	at org.apache.activemq.broker.region.RegionBroker.removeSubscription(RegionBroker.java:491)
	at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:102)
	at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:102)
	at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:102)
	at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:102)
	at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:102)
	at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:102)
	at org.apache.activemq.broker.MutableBrokerFilter.removeSubscription(MutableBrokerFilter.java:107)
	at org.apache.activemq.broker.TransportConnection.processRemoveSubscription(TransportConnection.java:345)
	at org.apache.activemq.command.RemoveSubscriptionInfo.visit(RemoveSubscriptionInfo.java:81)
	at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:310)
	at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:184)
	at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
	at org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:81)
	at org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:140)
	at org.apache.activemq.transport.stomp.ProtocolConverter.onStompUnsubscribe(ProtocolConverter.java:456)
	at org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommand(ProtocolConverter.java:190)
	at org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:70)
	at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
	at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:222)
	at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:204)
	at java.lang.Thread.run(Thread.java:662)

DISCONNECT

^@
Connection closed by foreign host.


[...]



Mime
View raw message