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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
