You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ar...@apache.org on 2007/09/19 17:25:18 UTC
svn commit: r577331 -
/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
Author: arnaudsimon
Date: Wed Sep 19 08:25:17 2007
New Revision: 577331
URL: http://svn.apache.org/viewvc?rev=577331&view=rev
Log:
changed method messageAcquire to test if the acquire range set is null
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=577331&r1=577330&r2=577331&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 Wed Sep 19 08:25:17 2007
@@ -317,7 +317,7 @@
.messageAcquire(ranges, org.apache.qpidity.nclient.Session.MESSAGE_ACQUIRE_ANY_AVAILABLE_MESSAGE);
_0_10session.getQpidSession().sync();
RangeSet acquired = _0_10session.getQpidSession().getAccquiredMessages();
- if (acquired.size() > 0)
+ if (acquired != null && acquired.size() > 0)
{
result = true;
}