diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index 2bbcf3271f..7cc2e54d96 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -366,8 +366,8 @@ slave_sync_loop(Args = {Ref, MRef, Syncer, BQ, UpdateRamDuration, Parent}, {BatchP, [{Msg, Props1} | BatchPD]} end, {[], []}, Batch), - BQS1 = BQ:batch_publish(BatchP1, BQS), - {AckTags, BQS2} = BQ:batch_publish_delivered(BatchPD1, BQS1), + BQS1 = BQ:batch_publish(BatchP1, none, noflow, BQS), + {AckTags, BQS2} = BQ:batch_publish_delivered(BatchPD1, none, noflow, BQS1), MA1 = lists:foldl(fun ({{Msg, _, _, _}, AckTag}, Acc) -> [{Msg#basic_message.id, AckTag} | Acc] |