summaryrefslogtreecommitdiff
path: root/src/rabbit_backing_queue.erl
diff options
context:
space:
mode:
authorEmile Joubert <emile@rabbitmq.com>2013-07-31 13:06:16 +0100
committerEmile Joubert <emile@rabbitmq.com>2013-07-31 13:06:16 +0100
commit09b934a686384267afdb28fe3b4bba4d9bcca78c (patch)
tree97db40e02fbc1aa2043d545da2dda08e046e7096 /src/rabbit_backing_queue.erl
parentac666e08c5405aa0b4e27a7edaaaf05d60e1e55e (diff)
parentd99108bf76d3ddb972683217ae3e3e62583d036c (diff)
downloadrabbitmq-server-09b934a686384267afdb28fe3b4bba4d9bcca78c.tar.gz
Refresh branch from stable
Diffstat (limited to 'src/rabbit_backing_queue.erl')
-rw-r--r--src/rabbit_backing_queue.erl12
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.