You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2014/02/20 16:41:04 UTC
svn commit: r1570233 -
/qpid/trunk/qpid/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Receiver.java
Author: rgodfrey
Date: Thu Feb 20 15:41:03 2014
New Revision: 1570233
URL: http://svn.apache.org/r1570233
Log:
QPID-5570 : Client incorrectly acknowledges prefetched messages with client-ack
Modified:
qpid/trunk/qpid/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Receiver.java
Modified: qpid/trunk/qpid/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Receiver.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Receiver.java?rev=1570233&r1=1570232&r2=1570233&view=diff
==============================================================================
--- qpid/trunk/qpid/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Receiver.java (original)
+++ qpid/trunk/qpid/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Receiver.java Thu Feb 20 15:41:03 2014
@@ -505,7 +505,7 @@ public class Receiver implements Deliver
_endpoint.setTarget(null);
_endpoint.close();
Message msg;
- while((msg = receive(-1l)) != null)
+ while((msg = receive(0l)) != null)
{
release(msg);
}
@@ -518,7 +518,7 @@ public class Receiver implements Deliver
_endpoint.setTarget(null);
_endpoint.detach();
Message msg;
- while((msg = receive(-1l)) != null)
+ while((msg = receive(0l)) != null)
{
release(msg);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org