diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2015-01-12 15:47:34 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2015-01-12 15:47:34 +0000 |
| commit | 8a605773ce360d3f29edbf639bebbd204d8c7b7a (patch) | |
| tree | b2cc6ce43455297f3fcb8b209c9d83b64e5e09c2 | |
| parent | 061f7339924c8b610840f223a22c56f4646c5c6b (diff) | |
| download | rabbitmq-server-git-8a605773ce360d3f29edbf639bebbd204d8c7b7a.tar.gz | |
Fix eager sync.
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index ee1d210556..9a8d55f94b 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -263,9 +263,10 @@ slave_sync_loop(Args = {Ref, MRef, Syncer, BQ, UpdateRamDuration, Parent}, Props1 = Props#message_properties{needs_confirming = false}, {MA1, BQS1} = case Unacked of - false -> {MA, BQ:publish(Msg, Props1, true, none, BQS)}; + false -> {MA, + BQ:publish(Msg, Props1, true, none, noflow, BQS)}; true -> {AckTag, BQS2} = BQ:publish_delivered( - Msg, Props1, none, BQS), + Msg, Props1, none, noflow, BQS), {[{Msg#basic_message.id, AckTag} | MA], BQS2} end, slave_sync_loop(Args, {MA1, TRef, BQS1}); |