You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Timothy Bish (JIRA)" <ji...@apache.org> on 2011/03/05 18:22:45 UTC
[jira] Resolved: (AMQ-3026) Statistics plugin sample hanging when
switching to http transport protocol
[ https://issues.apache.org/jira/browse/AMQ-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Timothy Bish resolved AMQ-3026.
-------------------------------
Resolution: Fixed
Fix Version/s: 5.5.0
Assignee: Timothy Bish
Fixed by AMQ-3202
> Statistics plugin sample hanging when switching to http transport protocol
> --------------------------------------------------------------------------
>
> Key: AMQ-3026
> URL: https://issues.apache.org/jira/browse/AMQ-3026
> Project: ActiveMQ
> Issue Type: Bug
> Components: Transport
> Affects Versions: 5.4.1
> Reporter: Jean-Yves Mengant
> Assignee: Timothy Bish
> Fix For: 5.5.0
>
>
> 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.
--
This message is automatically generated by JIRA.
-
For more information on JIRA, see: http://www.atlassian.com/software/jira