diff options
| -rw-r--r-- | src/rabbit_variable_queue.erl | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 15509b3c35..3378c435e6 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -854,8 +854,10 @@ tx_commit_post_msg_store(HasPersistentPubs, Pubs, AckTags, Fun, true -> State #vqstate { on_sync = { [AckTags | SAcks], [Pubs | SPubs], [Fun | SFuns] }}; - false -> State1 = tx_commit_index(State #vqstate { - on_sync = {[], [Pubs], [Fun]} }), + false -> State1 = tx_commit_index( + State #vqstate { on_sync = { [AckTags], + [Pubs], + [Fun]} }), State1 #vqstate { on_sync = OnSync } end. |