Author: arnaudsimon
Date: Mon Oct 29 11:07:26 2007
New Revision: 589777
URL: http://svn.apache.org/viewvc?rev=589777&view=rev
Log:
Changed for not acquiring messages if this is a browser
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java?rev=589777&r1=589776&r2=589777&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
Mon Oct 29 11:07:26 2007
@@ -308,7 +308,7 @@
}
// now we need to acquire this message if needed
// this is the case of queue with a message selector set
- if (!_preAcquire && messageOk)
+ if (!_preAcquire && messageOk && ! isNoConsume())
{
if (_logger.isDebugEnabled())
{
