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)
{
