You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ma...@apache.org on 2014/07/04 17:51:29 UTC
svn commit: r1607882 -
/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
Author: macbean
Date: Fri Jul 4 15:51:28 2014
New Revision: 1607882
URL: http://svn.apache.org/r1607882
Log:
QPID-5876: [Java Client] Highest delivery tag variable not reset after failover and causes rejections to be sent
Work by Keith Wall <kw...@apache.org> and me.
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
Modified: qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java?rev=1607882&r1=1607881&r2=1607882&view=diff
==============================================================================
--- qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java (original)
+++ qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java Fri Jul 4 15:51:28 2014
@@ -2271,6 +2271,7 @@ public abstract class AMQSession<C exten
_failedOverDirty = true;
}
+ _highestDeliveryTag.set(-1);
_rollbackMark.set(-1);
resubscribeProducers();
resubscribeConsumers();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org