qpid-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jarosław Kątnik (JIRA) <j...@apache.org>
Subject [jira] [Commented] (QPID-4901) [JMS AMQP 1.0] QueueBrowser hangs on reaching end of the queues
Date Mon, 16 Sep 2013 08:09:52 GMT

    [ https://issues.apache.org/jira/browse/QPID-4901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768148#comment-13768148
] 

Jarosław Kątnik commented on QPID-4901:
---------------------------------------

Hi

this issue is over half year old. 
I'm facing the same problem, is there any workaround?

Cheers
  Jarek
                
> [JMS AMQP 1.0] QueueBrowser hangs on reaching end of the queues
> ---------------------------------------------------------------
>
>                 Key: QPID-4901
>                 URL: https://issues.apache.org/jira/browse/QPID-4901
>             Project: Qpid
>          Issue Type: Bug
>          Components: Java Client
>    Affects Versions: 0.20, 0.22
>            Reporter: Alex Rudyy
>
> QueueBrowser hangs on reaching an end of the queues. The following code reproduced the
issue:
> {code:java}
> Queue queue = QueueImpl.createQueue("testQueue");
> ConnectionFactory factory = new ConnectionFactoryImpl("localhost", 5672, "admin", "admin");
> Connection producerConnection = factory.createConnection();
> Session producerSession = producerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
> MessageProducer producer = producerSession.createProducer(queue);
> producer.send(producerSession.createTextMessage("message 1"));
> producer.send(producerSession.createTextMessage("message 2"));
> producerConnection.close();
> Connection browserConnection = factory.createConnection();
> Session browserSession = browserConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
> QueueBrowser browser = browserSession.createBrowser(queue);
> @SuppressWarnings("rawtypes")
> Enumeration enumeration = browser.getEnumeration();
> while (enumeration.hasMoreElements()) // <--- hangs here
> {
>     TextMessage msg = (TextMessage) enumeration.nextElement();
>     System.out.println("Browser received:" + msg.getText());
> }
> browserConnection.close();
> {code}
> Here is the stack trace from the main thread:
> {noformat}
> "main" prio=10 tid=0x00007fc3c4008000 nid=0x1870 in Object.wait() [0x00007fc3ca3cb000]
>    java.lang.Thread.State: WAITING (on object monitor)
> 	at java.lang.Object.wait(Native Method)
> 	- waiting on <0x00000000ec3367b0> (a org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint)
> 	at java.lang.Object.wait(Object.java:485)
> 	at org.apache.qpid.amqp_1_0.client.Receiver.drainWait(Receiver.java:533)
> 	- locked <0x00000000ec3367b0> (a org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint)
> 	at org.apache.qpid.amqp_1_0.jms.impl.QueueBrowserImpl$MessageEnumeration.hasMoreElements(QueueBrowserImpl.java:154)
> 	at org.apache.qpid.test.QueueBrowserTest.main(QueueBrowserTest.java:38)
> {noformat}

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@qpid.apache.org
For additional commands, e-mail: dev-help@qpid.apache.org


Mime
View raw message