diff options
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index af4cb0cad5..2bbcf3271f 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -358,11 +358,13 @@ slave_sync_loop(Args = {Ref, MRef, Syncer, BQ, UpdateRamDuration, Parent}, fun ({Msg, Props, false}, {BatchP, BatchPD}) -> Props1 = Props#message_properties{ needs_confirming = false}, - {[{Msg, Props1, true, none, noflow} | BatchP], BatchPD}; + {[{Msg, Props1, true} | BatchP], + BatchPD}; ({Msg, Props, true}, {BatchP, BatchPD}) -> Props1 = Props#message_properties{ needs_confirming = false}, - {BatchP, [{Msg, Props1, none, noflow} | BatchPD]} + {BatchP, + [{Msg, Props1} | BatchPD]} end, {[], []}, Batch), BQS1 = BQ:batch_publish(BatchP1, BQS), {AckTags, BQS2} = BQ:batch_publish_delivered(BatchPD1, BQS1), |