Dejan Bosanac <de...@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.
[...]
