diff options
| author | Rob Harrop <rob@rabbitmq.com> | 2011-05-16 14:58:55 +0100 |
|---|---|---|
| committer | Rob Harrop <rob@rabbitmq.com> | 2011-05-16 14:58:55 +0100 |
| commit | 7bc8f4795784f39d3c815c420e7658a1a0768966 (patch) | |
| tree | 85b1db0e003558f184738d8a4fd12b0f42624487 | |
| parent | d9c63025e730f6b85e78e7dcae49d4c28757e72d (diff) | |
| download | rabbitmq-server-git-7bc8f4795784f39d3c815c420e7658a1a0768966.tar.gz | |
Fixed call to validate_message
| -rw-r--r-- | src/rabbit_mirror_queue_master.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_master.erl b/src/rabbit_mirror_queue_master.erl index 481ee7c49d..f54c8c379b 100644 --- a/src/rabbit_mirror_queue_master.erl +++ b/src/rabbit_mirror_queue_master.erl @@ -287,7 +287,7 @@ is_duplicate(none, Message = #basic_message { id = MsgId }, error -> %% We permit the underlying BQ to have a peek at it, but %% only if we ourselves are not filtering out the msg. - {Result, BQS1} = BQ:validate_message(Message, BQS), + {Result, BQS1} = BQ:is_duplicate(none, Message, BQS), {Result, State #state { backing_queue_state = BQS1 }}; {ok, published} -> %% It already got published when we were a slave and no |