qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arnaudsi...@apache.org
Subject svn commit: r588678 - in /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client: AMQQueueBrowser.java AMQSession_0_10.java
Date Fri, 26 Oct 2007 15:07:21 GMT
Author: arnaudsimon
Date: Fri Oct 26 08:07:20 2007
New Revision: 588678

URL: http://svn.apache.org/viewvc?rev=588678&view=rev
Log:
Changed queue browsing behavior: added timeout for receiveing next message and set acquire
mode to false

Modified:
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.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=588678&r1=588677&r2=588678&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
Fri Oct 26 08:07:20 2007
@@ -109,7 +109,7 @@
                     {
                         _logger.info("QB:nextElement about to receive");
 
-                        _nextMessage = consumer.receive();
+                        _nextMessage = consumer.receive(1000);
                         _logger.info("QB:nextElement received:" + _nextMessage);
                     }
                     catch (JMSException e)

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java?rev=588678&r1=588677&r2=588678&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Fri Oct 26 08:07:20 2007
@@ -343,7 +343,7 @@
         boolean preAcquire;
         try
         {
-            preAcquire = consumer.getMessageSelector() == null || !(consumer.getDestination()
instanceof AMQQueue);
+            preAcquire = ( ! consumer.isNoConsume()  && consumer.getMessageSelector()
== null) || !(consumer.getDestination() instanceof AMQQueue);
         }
         catch (JMSException e)
         {



Mime
View raw message