diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-11-23 17:28:35 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-11-23 17:28:35 +0000 |
| commit | fdae19d2bef119ff8652fa7a74d3e2b063ac8437 (patch) | |
| tree | c4f5c5d376b282e67dfa2ccacc9e32f68f2387cd /src | |
| parent | cfe5aa3fbf644ec69bab8a50e2c6e6bd531b1e5a (diff) | |
| download | rabbitmq-server-git-fdae19d2bef119ff8652fa7a74d3e2b063ac8437.tar.gz | |
Oops
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 3 |
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); |
