diff options
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index bf80426626..f31979d9b6 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -138,7 +138,7 @@ master_batch_send({Syncer, Ref, Log, HandleInfo, EmitStats, Parent}, T = maybe_emit_stats(Last, I, EmitStats, Log), HandleInfo({syncing, I}), handle_set_maximum_since_use(), - SyncMsg = {msgs, Ref, Batch}, + SyncMsg = {msgs, Ref, lists:reverse(Batch)}, NewAcc = {[], I + length(Batch), {Curr, Len}, T}, master_send_receive(SyncMsg, NewAcc, Syncer, Ref, Parent). |