Stomp error on unsubscribe of durable consumer
Hello,
To subscribe and unsubscribe a durable consumer I use these frames:
SUBSCRIBE
destination:jms.topic.ExampleTopic
ack:auto
id:{C985B5E0-B5CD-4567-82B2-CCA5B108D53D}
durable-subscriber-name:test
and
UNSUBSCRIBE
destination:jms.topic.ExampleTopic
durable-subscriber-name:test
But the broker (2.1.2.Final) does not understand the unsubscribe frame.
How do I specify the durable subscriber correctly?
The unsub frame causes this error in the broker:
[main] 17:02:36,988 INFO [org.hornetq.core.server.impl.HornetQServerImpl] Horne
tQ Server version 2.1.2.Final (Colmeia, 120) started
org.hornetq.core.protocol.stomp.StompException: Cannot unsubscribe as no subscri
ption exists for id: subscription/jms.topic.ExampleTopic
at org.hornetq.core.protocol.stomp.StompProtocolManager.onUnsubscribe(St
ompProtocolManager.java:364)
at org.hornetq.core.protocol.stomp.StompProtocolManager.doHandleBuffer(S
tompProtocolManager.java:186)
at org.hornetq.core.protocol.stomp.StompProtocolManager.handleBuffer(Sto
mpProtocolManager.java:145)
at org.hornetq.core.protocol.stomp.StompConnection.bufferReceived(StompC
onnection.java:152)
at org.hornetq.core.remoting.server.impl.RemotingServiceImpl$DelegatingB
ufferHandler.bufferReceived(RemotingServiceImpl.java:459)
at org.hornetq.core.remoting.impl.netty.HornetQChannelHandler.messageRec
eived(HornetQChannelHandler.java:67)
at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleCha
nnelHandler.java:100)
at org.jboss.netty.channel.StaticChannelPipeline.sendUpstream(StaticChan
nelPipeline.java:362)
at org.jboss.netty.channel.StaticChannelPipeline$StaticChannelHandlerCon
text.sendUpstream(StaticChannelPipeline.java:514)
at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:30
2)
at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessage
Received(FrameDecoder.java:317)
at org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDeco
der.java:299)
at org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(Fram
eDecoder.java:214)
at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(S
impleChannelUpstreamHandler.java:80)
at org.jboss.netty.channel.StaticChannelPipeline.sendUpstream(StaticChan
nelPipeline.java:362)
at org.jboss.netty.channel.StaticChannelPipeline.sendUpstream(StaticChan
nelPipeline.java:357)
at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:27
4)
at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:26
1)
at org.jboss.netty.channel.socket.oio.OioWorker.run(OioWorker.java:90)
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnabl
e.java:108)
at org.jboss.netty.util.internal.IoWorkerRunnable.run(IoWorkerRunnable.j
ava:46)
at org.jboss.netty.util.VirtualExecutorService$ChildExecutorRunnable.run
(VirtualExecutorService.java:181)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source
)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
org.hornetq.core.protocol.stomp.StompException: Cannot unsubscribe as no subscri
ption exists for id: subscription/jms.topic.ExampleTopic
at org.hornetq.core.protocol.stomp.StompProtocolManager.onUnsubscribe(St
ompProtocolManager.java:364)
at org.hornetq.core.protocol.stomp.StompProtocolManager.doHandleBuffer(S
tompProtocolManager.java:186)
at org.hornetq.core.protocol.stomp.StompProtocolManager.handleBuffer(Sto
mpProtocolManager.java:145)
at org.hornetq.core.protocol.stomp.StompConnection.bufferReceived(StompC
onnection.java:152)
at org.hornetq.core.remoting.server.impl.RemotingServiceImpl$DelegatingB
ufferHandler.bufferReceived(RemotingServiceImpl.java:459)
at org.hornetq.core.remoting.impl.netty.HornetQChannelHandler.messageRec
eived(HornetQChannelHandler.java:67)
at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleCha
nnelHandler.java:100)
at org.jboss.netty.channel.StaticChannelPipeline.sendUpstream(StaticChan
nelPipeline.java:362)
at org.jboss.netty.channel.StaticChannelPipeline$StaticChannelHandlerCon
text.sendUpstream(StaticChannelPipeline.java:514)
at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:30
2)
at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessage
Received(FrameDecoder.java:317)
at org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDeco
der.java:299)
at org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(Fram
eDecoder.java:214)
at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(S
impleChannelUpstreamHandler.java:80)
at org.jboss.netty.channel.StaticChannelPipeline.sendUpstream(StaticChan
nelPipeline.java:362)
at org.jboss.netty.channel.StaticChannelPipeline.sendUpstream(StaticChan
nelPipeline.java:357)
at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:27
4)
at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:26
1)
at org.jboss.netty.channel.socket.oio.OioWorker.run(OioWorker.java:90)
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnabl
e.java:108)
at org.jboss.netty.util.internal.IoWorkerRunnable.run(IoWorkerRunnable.j
ava:46)
at org.jboss.netty.util.VirtualExecutorService$ChildExecutorRunnable.run
(VirtualExecutorService.java:181)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source
)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
org.hornetq.core.protocol.stomp.StompException: Cannot unsubscribe as no subscri
ption exists for id: subscription/jms.topic.ExampleTopic
at org.hornetq.core.protocol.stomp.StompProtocolManager.onUnsubscribe(St
ompProtocolManager.java:364)
at org.hornetq.core.protocol.stomp.StompProtocolManager.doHandleBuffer(S
tompProtocolManager.java:186)
at org.hornetq.core.protocol.stomp.StompProtocolManager.handleBuffer(Sto
mpProtocolManager.java:145)
at org.hornetq.core.protocol.stomp.StompConnection.bufferReceived(StompC
onnection.java:152)
at org.hornetq.core.remoting.server.impl.RemotingServiceImpl$DelegatingB
ufferHandler.bufferReceived(RemotingServiceImpl.java:459)
at org.hornetq.core.remoting.impl.netty.HornetQChannelHandler.messageRec
eived(HornetQChannelHandler.java:67)
at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleCha
nnelHandler.java:100)
at org.jboss.netty.channel.StaticChannelPipeline.sendUpstream(StaticChan
nelPipeline.java:362)
at org.jboss.netty.channel.StaticChannelPipeline$StaticChannelHandlerCon
text.sendUpstream(StaticChannelPipeline.java:514)
at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:30
2)
at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessage
Received(FrameDecoder.java:317)
at org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDeco
der.java:299)
at org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(Fram
eDecoder.java:214)
at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(S
impleChannelUpstreamHandler.java:80)
at org.jboss.netty.channel.StaticChannelPipeline.sendUpstream(StaticChan
nelPipeline.java:362)
at org.jboss.netty.channel.StaticChannelPipeline.sendUpstream(StaticChan
nelPipeline.java:357)
at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:27
4)
at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:26
1)
at org.jboss.netty.channel.socket.oio.OioWorker.run(OioWorker.java:90)
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnabl
e.java:108)
at org.jboss.netty.util.internal.IoWorkerRunnable.run(IoWorkerRunnable.j
ava:46)
at org.jboss.netty.util.VirtualExecutorService$ChildExecutorRunnable.run
(VirtualExecutorService.java:181)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source
)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)