[
https://issues.apache.org/jira/browse/QPID-4901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13776437#comment-13776437
]
clebert suconic commented on QPID-4901:
---------------------------------------
I'm facing this issue on this test here:
https://github.com/hornetq/hornetq/blob/master/tests/integration-tests/src/test/java/org/hornetq/tests/integration/proton/ProtonTest.java
a simple browsing will lead to the hanging
> [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: [email protected]
For additional commands, e-mail: [email protected]
