don't remove rejected message before it is confirmed by the DLQ

1 files changed, 4 insertions, 7 deletions

diff --git a/src/rabbit_backing_queue.erl b/src/rabbit_backing_queue.erl
index a80d656d..72c00e3d 100644
--- a/src/rabbit_backing_queue.erl
+++ b/src/rabbit_backing_queue.erl
@@ -97,9 +97,8 @@ behaviour_info(callbacks) ->
      %% Drop messages from the head of the queue while the supplied
      %% predicate returns true. A callback function is supplied
      %% allowing callers access to messages that are about to be
-     %% dropped; the callback may publish messages and requires the
-     %% next message sequence number, which must also be supplied.
-     {dropwhile, 4},
+     %% dropped.
+     {dropwhile, 3},
 
      %% Produce the next message.
      {fetch, 2},
@@ -107,10 +106,8 @@ behaviour_info(callbacks) ->
      %% Acktags supplied are for messages which can now be forgotten
      %% about. Must return 1 msg_id per Ack, in the same order as
      %% Acks. A callback function is supplied allowing callers to
-     %% access messages that are being acked; the callback may publish
-     %% messages and requires the next message sequence number, which
-     %% must also be supplied.
-     {ack, 4},
+     %% access messages that are being acked.
+     {ack, 3},
 
      %% Reinsert messages into the queue which have already been
      %% delivered and were pending acknowledgement.