0 Replies Latest reply on Feb 10, 2011 12:01 PM by bl5536

    Stomp subcription to HornetQ queue problem

    bl5536

      Hello all, I have a weird error so let me try to explain.

       

      I am using a simple java client to connect, send and subcribe to queues.

       

      If I subcribe to a jms queue,  there is no problem. They send and receive perfectly fine.

       

      The problem is with a hornetq queue, defined like this in hornetq-configuration.xml :

       

      <queues>
              <queue name="queue.stomp.Inbound">
                  <address>/queue/Inbound</address>
              </queue>
      </queues>
      
      

       

      And with a small java program that uses the stomp protocol: gozirra stomp client

       

       

      Map res = null;
      res = subscribe(c,listenQueue);
      c.send(destQueue, temp);
      
      result = (ArrayList<String>) res.get("MESSAGE");
      for (String s : result){
           System.out.println("Messages received from queue : " + s);
      }
      c.disconnect(); 
      

      This is just a small snippet of the code that is simplified for this example.

       

      where all the variables are inputted correctly. Works fine with jms queues, but not the HornetQ queues.

       

      I also stepped through the process and when I am not subscribing, I see messages pile up on the queue through the jmx console. However the moment I subscribe, they are all gone and the returning Map is empty.

       

      Does anyone have any insight to this situation?

       

      Thanks in advance