diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-11-14 12:05:05 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-11-14 12:05:05 +0000 |
| commit | 12eea5e00a656f2dda3888ff089f7c4d47acb40c (patch) | |
| tree | 82ab6fb66a67644e17cb7048ea83b9064530ccdf /src/rabbit_backing_queue.erl | |
| parent | 62facff84cb5aee19de9385d618fcea3ef622218 (diff) | |
| download | rabbitmq-server-12eea5e00a656f2dda3888ff089f7c4d47acb40c.tar.gz | |
amqqueue_process re-publishes with confirms
Diffstat (limited to 'src/rabbit_backing_queue.erl')
| -rw-r--r-- | src/rabbit_backing_queue.erl | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/src/rabbit_backing_queue.erl b/src/rabbit_backing_queue.erl index 72c00e3d..a80d656d 100644 --- a/src/rabbit_backing_queue.erl +++ b/src/rabbit_backing_queue.erl @@ -97,8 +97,9 @@ 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. - {dropwhile, 3}, + %% dropped; the callback may publish messages and requires the + %% next message sequence number, which must also be supplied. + {dropwhile, 4}, %% Produce the next message. {fetch, 2}, @@ -106,8 +107,10 @@ 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. - {ack, 3}, + %% 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}, %% Reinsert messages into the queue which have already been %% delivered and were pending acknowledgement. |