ActiveMQ
  1. ActiveMQ
  2. AMQ-3026

Statistics plugin sample hanging when switching to http transport protocol

    Details

    • Type: Bug Bug
    • Status: Resolved
    • Priority: Major Major
    • Resolution: Fixed
    • Affects Version/s: 5.4.1
    • Fix Version/s: 5.5.0
    • Component/s: Transport
    • Labels:
      None

      Description

      When running using HTTP transport connector the provided sample ActiveMQ stat sample hangs on the :
      MapMessage reply = (MapMessage) consumer.receive();

      to reproduce :
      just use the activeMQ provided sample statistics plugin sample copied below :

      ActiveMQSession session = broker.getSession() ;
      Queue replyTo = session.createTemporaryQueue();
      MessageConsumer consumer = session.createConsumer(replyTo);

      Queue testQueue = session.createQueue("TEST.FOO");
      MessageProducer producer = session.createProducer(null);

      String queueName = "ActiveMQ.Statistics.Destination." + testQueue.getQueueName() ;
      Queue query = session.createQueue(queueName);

      Message msg = session.createMessage();

      producer.send(testQueue, msg) ;
      msg.setJMSReplyTo(replyTo);
      producer.send(query, msg);
      MapMessage reply = (MapMessage) consumer.receive();
      assertNotNull(reply);
      assertTrue(reply.getMapNames().hasMoreElements());

      for (Enumeration e = reply.getMapNames();e.hasMoreElements()

      { String name = e.nextElement().toString(); System.err.println(name + "=" + reply.getObject(name)); }

      1) Check that it works correclty using an ActiveMQ TCPIP based session. ===> OK
      2) just replace the ActiveMQ TCPIP based session by an HTTP transport session. ===> KO

      The sample will remain unresponsive on the : MapMessage reply = (MapMessage) consumer.receive(); instruction then.

        Issue Links

          Activity

            People

            • Assignee:
              Timothy Bish
              Reporter:
              Jean-Yves Mengant
            • Votes:
              0 Vote for this issue
              Watchers:
              0 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development