0 Replies Latest reply on Mar 9, 2011 11:10 AM by Michael Justin

    Stomp error on unsubscribe of durable consumer

    Michael Justin Novice

      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)