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 | daa21c9c268e2a332be0ecb74ff834f61d4c92a0 (patch) | |
| tree | b2cc6ce43455297f3fcb8b209c9d83b64e5e09c2 | |
| parent | 2749a34caf8a2d1e1eca41bae2f07fd43526610b (diff) | |
| download | rabbitmq-server-bug26527.tar.gz | |
Fix eager sync.bug26527
| -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 ee1d2105..9a8d55f9 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}); |