diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-11-19 11:16:36 +0100 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-11-19 11:16:36 +0100 |
| commit | e68a94e720cc2862fe5b572800cbdef135bcafcd (patch) | |
| tree | a28433be08e39e92cdfae95f0f1867c52a588df3 | |
| parent | 6fcfd70d7e70134fa007a448240d10dbfda8c344 (diff) | |
| download | rabbitmq-server-git-e68a94e720cc2862fe5b572800cbdef135bcafcd.tar.gz | |
adds missing state param
| -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 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) -> |