diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-19 21:32:01 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-19 21:32:01 +0000 |
| commit | f27c502034c9e5218e280c4a39da88562b466f51 (patch) | |
| tree | 59b17d795623020fc51080882dd0331f4af0ea20 /src/rabbit_mirror_queue_slave.erl | |
| parent | 005788d47882dade23b7c3b605bcafde4107222d (diff) | |
| download | rabbitmq-server-f27c502034c9e5218e280c4a39da88562b466f51.tar.gz | |
populate slave's msg_id_ack with sync'ed messages pending ackbug25394
Diffstat (limited to 'src/rabbit_mirror_queue_slave.erl')
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index b63fccc9..cd2a8042 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -227,9 +227,12 @@ handle_cast({sync_start, Ref, Syncer}, backing_queue = BQ, backing_queue_state = BQS }) -> State1 = #state{rate_timer_ref = TRef} = ensure_rate_timer(State), - S = fun({TRefN, BQSN}) -> State1#state{depth_delta = undefined, - rate_timer_ref = TRefN, - backing_queue_state = BQSN} end, + S = fun({MA, TRefN, BQSN}) -> + State1#state{depth_delta = undefined, + msg_id_ack = dict:from_list(MA), + rate_timer_ref = TRefN, + backing_queue_state = BQSN} + end, case rabbit_mirror_queue_sync:slave( DD, Ref, TRef, Syncer, BQ, BQS, fun (BQN, BQSN) -> |