diff options
author | Emile Joubert <emile@rabbitmq.com> | 2013-07-31 13:06:16 +0100 |
---|---|---|
committer | Emile Joubert <emile@rabbitmq.com> | 2013-07-31 13:06:16 +0100 |
commit | 09b934a686384267afdb28fe3b4bba4d9bcca78c (patch) | |
tree | 97db40e02fbc1aa2043d545da2dda08e046e7096 /src/rabbit_backing_queue.erl | |
parent | ac666e08c5405aa0b4e27a7edaaaf05d60e1e55e (diff) | |
parent | d99108bf76d3ddb972683217ae3e3e62583d036c (diff) | |
download | rabbitmq-server-09b934a686384267afdb28fe3b4bba4d9bcca78c.tar.gz |
Refresh branch from stable
Diffstat (limited to 'src/rabbit_backing_queue.erl')
-rw-r--r-- | src/rabbit_backing_queue.erl | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/src/rabbit_backing_queue.erl b/src/rabbit_backing_queue.erl index f05e46e9..61b504bc 100644 --- a/src/rabbit_backing_queue.erl +++ b/src/rabbit_backing_queue.erl @@ -90,10 +90,7 @@ -> {ack(), state()}. %% Called to inform the BQ about messages which have reached the -%% queue, but are not going to be further passed to BQ for some -%% reason. Note that this may be invoked for messages for which -%% BQ:is_duplicate/2 has already returned {'published' | 'discarded', -%% BQS}. +%% queue, but are not going to be further passed to BQ. -callback discard(rabbit_types:msg_id(), pid(), state()) -> state(). %% Return ids of messages which have been confirmed since the last @@ -216,11 +213,10 @@ -callback invoke(atom(), fun ((atom(), A) -> A), state()) -> state(). %% Called prior to a publish or publish_delivered call. Allows the BQ -%% to signal that it's already seen this message (and in what capacity -%% - i.e. was it published previously or discarded previously) and -%% thus the message should be dropped. +%% to signal that it's already seen this message, (e.g. it was published +%% or discarded previously) and thus the message should be dropped. -callback is_duplicate(rabbit_types:basic_message(), state()) - -> {'false'|'published'|'discarded', state()}. + -> {boolean(), state()}. -else. |