Fix wrong tag

tsotnikov · acogoluegnes · commit d4b4e95d91b5 · 2018-01-09T11:20:34.000+01:00
diff --git a/src/main/java/com/rabbitmq/client/impl/recovery/RecoveryAwareChannelN.java b/src/main/java/com/rabbitmq/client/impl/recovery/RecoveryAwareChannelN.java
@@ -87,7 +87,7 @@ public void basicAck(long deliveryTag, boolean multiple) throws IOException {
         long realTag = deliveryTag - activeDeliveryTagOffset;
         // 0 tag means ack all
         if (realTag >= 0) {
-            transmit(new Basic.Ack(deliveryTag, multiple));
+            transmit(new Basic.Ack(realTag, multiple));
             metricsCollector.basicAck(this, deliveryTag, multiple);
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -87,7 +87,7 @@ public void basicAck(long deliveryTag, boolean multiple) throws IOException {`
`87`	`87`	`long realTag = deliveryTag - activeDeliveryTagOffset;`
`88`	`88`	`// 0 tag means ack all`
`89`	`89`	`if (realTag >= 0) {`
`90`		`- transmit(new Basic.Ack(deliveryTag, multiple));`
	`90`	`+ transmit(new Basic.Ack(realTag, multiple));`
`91`	`91`	`metricsCollector.basicAck(this, deliveryTag, multiple);`
`92`	`92`	`}`
`93`	`93`	`}`