diff options
| -rw-r--r-- | src/rabbit_mixed_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_mixed_queue.erl b/src/rabbit_mixed_queue.erl index f6ef355d9b..26fa029db7 100644 --- a/src/rabbit_mixed_queue.erl +++ b/src/rabbit_mixed_queue.erl @@ -146,8 +146,8 @@ to_disk_only_mode(TxnMessages, State = end; ({disk, Count}, {RQueueAcc, TxPublishAcc}) -> ok = if [] == TxPublishAcc -> ok; - true -> rabbit_disk_queue:tx_commit(Q, TxPublishAcc, - []) + true -> + rabbit_disk_queue:tx_commit(Q, TxPublishAcc, []) end, {RQueueAcc1, 0} = rabbit_misc:unfold( |