diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2012-02-24 13:10:40 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2012-02-24 13:10:40 +0000 |
| commit | 90741883151abc631a99629ae98fda8a3f86b025 (patch) | |
| tree | f923b129ee77dce6cf9c3a902d2be6b854f0a005 /src/rabbit_backing_queue.erl | |
| parent | 2a02ae5f8b5ef1a5635dbe0367c4445a83cbee45 (diff) | |
| download | rabbitmq-server-90741883151abc631a99629ae98fda8a3f86b025.tar.gz | |
rename the weird VQ:ack/3 head to VQ:process_messages/3
Diffstat (limited to 'src/rabbit_backing_queue.erl')
| -rw-r--r-- | src/rabbit_backing_queue.erl | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/src/rabbit_backing_queue.erl b/src/rabbit_backing_queue.erl index 50e47462..11dcfa35 100644 --- a/src/rabbit_backing_queue.erl +++ b/src/rabbit_backing_queue.erl @@ -105,9 +105,13 @@ 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}, + %% Acks. + {ack, 2}, + + %% Acktags supplied are for messages which should be + %% processed. The provided callback function is called with each + %% message. + {process_messages, 3}, %% Reinsert messages into the queue which have already been %% delivered and were pending acknowledgement. |