[
https://issues.apache.org/jira/browse/QPID-4901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13778830#comment-13778830
]
Rob Godfrey commented on QPID-4901:
-----------------------------------
This change has no effect on Proton... I'm not sure whether there are any
Proton issues per se (as long as it can pass on the fact that the requested
source is of distribution mode "copy", that it can pass on the fact that the
client wishes to drain the queue, and that it respects the echo flag on
"flow").
> [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
> Assignee: Rob Godfrey
> Fix For: 0.25
>
>
> 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]
