This is a fix for QPID-791

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@627629 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 1 insertions, 4 deletions

diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java b/java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java
index fc6ebad1c0..f56477c0fc 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java
@@ -92,13 +92,11 @@ public class AMQQueueBrowser implements QueueBrowser
 
         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 @@ public class AMQQueueBrowser implements QueueBrowser
                     try
                     {
                         _logger.info("QB:nextElement about to receive");
-
                         _nextMessage = consumer.receive(1000);
                         _logger.info("QB:nextElement received:" + _nextMessage);
                     }