diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-10 23:24:54 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-10 23:24:54 +0200 |
| commit | b43b3b9ba8ea60651dbae86e81f2da4ddf9f67a4 (patch) | |
| tree | dca7ee98c86b25531b91c7558543e0b2e4f0270b | |
| parent | 1a0a00c2bc3a9b1562c287330c689a36641822b2 (diff) | |
| download | rabbitmq-server-git-b43b3b9ba8ea60651dbae86e81f2da4ddf9f67a4.tar.gz | |
send msg batch in proper order
| -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). |