expose multiple in AckListener

Alexandru Scvortov · Alexandru Scvortov · commit 3dc3a7819483 · 2010-08-12T09:43:29.000+01:00
diff --git a/src/com/rabbitmq/client/AckListener.java b/src/com/rabbitmq/client/AckListener.java
@@ -38,6 +38,6 @@
  * events.
  */
 public interface AckListener {
-    void handleAck(long sequenceNumber)
+    void handleAck(long deliveryTag, boolean multiple)
         throws IOException;
 }
diff --git a/src/com/rabbitmq/client/impl/ChannelN.java b/src/com/rabbitmq/client/impl/ChannelN.java
@@ -334,7 +334,7 @@ public void releaseChannelNumber() {
                 AckListener l = getAckListener();
                 if (l != null) {
                     try {
-                        l.handleAck(ack.getDeliveryTag());
+                        l.handleAck(ack.getDeliveryTag(), ack.getMultiple());
                     } catch (Throwable ex) {
                         _connection.getExceptionHandler().handleAckListenerException(this, ex);
                     }

Original file line number	Diff line number	Diff line change
`@@ -38,6 +38,6 @@`
`38`	`38`	`* events.`
`39`	`39`	`*/`
`40`	`40`	`public interface AckListener {`
`41`		`- void handleAck(long sequenceNumber)`
	`41`	`+ void handleAck(long deliveryTag, boolean multiple)`
`42`	`42`	`throws IOException;`
`43`	`43`	`}`
Original file line number	Diff line number	Diff line change
`@@ -334,7 +334,7 @@ public void releaseChannelNumber() {`
`334`	`334`	`AckListener l = getAckListener();`
`335`	`335`	`if (l != null) {`
`336`	`336`	`try {`
`337`		`- l.handleAck(ack.getDeliveryTag());`
	`337`	`+ l.handleAck(ack.getDeliveryTag(), ack.getMultiple());`
`338`	`338`	`} catch (Throwable ex) {`
`339`	`339`	`_connection.getExceptionHandler().handleAckListenerException(this, ex);`
`340`	`340`	`}`