diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-04 23:42:26 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-05 00:26:50 +0200 |
| commit | b813c420d7f00e7410bcff901a366356cf61dd12 (patch) | |
| tree | 97b26a9492f37d7131a6db409f2b01d61aa5b349 /src | |
| parent | 332c389a308cd0e6679d434ea709b4490f33f721 (diff) | |
| download | rabbitmq-server-git-b813c420d7f00e7410bcff901a366356cf61dd12.tar.gz | |
cosmetics
Diffstat (limited to 'src')
| -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), |