summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_mirror_queue_sync.erl2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl
index e9717743dc..2d8bdfa860 100644
--- a/src/rabbit_mirror_queue_sync.erl
+++ b/src/rabbit_mirror_queue_sync.erl
@@ -354,7 +354,7 @@ batch_publish(Batch, MA, BQ, BQS) ->
batch_publish_delivered(Batch, MA, BQ, BQS) ->
{AckTags, BQS1} = BQ:batch_publish_delivered(Batch, none, noflow, BQS),
- MA1 = BQ:zip_msgs_and_acks(Batch, AckTags, MA),
+ MA1 = BQ:zip_msgs_and_acks(Batch, AckTags, MA, BQS1),
{MA1, BQS1}.
props(Props) ->