You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ra...@apache.org on 2008/02/14 02:08:59 UTC
svn commit: r627629 -
/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java
Author: rajith
Date: Wed Feb 13 17:08:58 2008
New Revision: 627629
URL: http://svn.apache.org/viewvc?rev=627629&view=rev
Log:
This is a fix for QPID-791
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java
Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java?rev=627629&r1=627628&r2=627629&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java (original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java Wed Feb 13 17:08:58 2008
@@ -92,13 +92,11 @@
return new Enumeration()
{
-
- Message _nextMessage = consumer.receive();
+ Message _nextMessage = consumer.receive(1000);
public boolean hasMoreElements()
{
_logger.info("QB:hasMoreElements:" + (_nextMessage != null));
-
return (_nextMessage != null);
}
@@ -108,7 +106,6 @@
try
{
_logger.info("QB:nextElement about to receive");
-
_nextMessage = consumer.receive(1000);
_logger.info("QB:nextElement received:" + _nextMessage);
}