diff options
Diffstat (limited to 'src')
| -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 7cc2e54d96..d7ed9484b5 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -127,7 +127,7 @@ master_batch_go0(Args, BatchSize, BQ, BQS) -> FoldFun = fun (Msg, MsgProps, Unacked, Acc) -> Acc1 = append_to_acc(Msg, MsgProps, Unacked, Acc), - case maybe_master_batch_send(Acc, BatchSize) of + case maybe_master_batch_send(Acc1, BatchSize) of true -> master_batch_send(Args, Acc1); false -> {cont, Acc1} end |