summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2012-11-23 17:28:35 +0000
committerSimon MacMullen <simon@rabbitmq.com>2012-11-23 17:28:35 +0000
commitfdae19d2bef119ff8652fa7a74d3e2b063ac8437 (patch)
treec4f5c5d376b282e67dfa2ccacc9e32f68f2387cd /src
parentcfe5aa3fbf644ec69bab8a50e2c6e6bd531b1e5a (diff)
downloadrabbitmq-server-git-fdae19d2bef119ff8652fa7a74d3e2b063ac8437.tar.gz
Oops
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_mirror_queue_slave.erl3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl
index c1d2e8e44f..a8615cee4b 100644
--- a/src/rabbit_mirror_queue_slave.erl
+++ b/src/rabbit_mirror_queue_slave.erl
@@ -850,7 +850,8 @@ sync_loop(Ref, MRef, MPid, State = #state{backing_queue = BQ,
%% sync with a newly promoted master, or even just receive
%% messages from it, we have a hole in the middle. So the
%% only thing to do here is purge.)
- State#state{backing_queue_state = BQ:purge(BQS)};
+ {_MsgCount, BQS1} = BQ:purge(BQS),
+ State#state{backing_queue_state = BQS1};
{bump_credit, Msg} ->
credit_flow:handle_bump_msg(Msg),
sync_loop(Ref, MRef, MPid, State);