diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-04 23:43:00 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-05 00:26:54 +0200 |
| commit | b6f44d6a25ee2605a5eff5ca36ab52fa0e669f28 (patch) | |
| tree | ab84f1ea17e77bd1b8d0229ca3fec023ae2127f8 /src | |
| parent | b813c420d7f00e7410bcff901a366356cf61dd12 (diff) | |
| download | rabbitmq-server-git-b6f44d6a25ee2605a5eff5ca36ab52fa0e669f28.tar.gz | |
fixes arguments passed to batch_publish_*
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] |