[AMQ-3026] Statistics plugin sample hanging when switching to http transport protocol

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 5.4.1
• Fix Version/s: 5.5.0
• Component/s: Transport
• Assignee: Timothy A. Bish
• Reporter: Jean-Yves Mengant
• Created: 09/Nov/10 18:24
• Updated: 05/Mar/11 17:20
• Resolved: 05/Mar/11 17:20

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

• blocks: AMQ-3202 Sending an Empty MapMessage over HttpTransport fails with exception