diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mixed_queue.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_mixed_queue.erl b/src/rabbit_mixed_queue.erl index 1e7d3287fc..788b4b5a2f 100644 --- a/src/rabbit_mixed_queue.erl +++ b/src/rabbit_mixed_queue.erl @@ -389,9 +389,8 @@ set_storage_mode(mixed, TxnMessages, State = %% durable). This is necessary to avoid leaks. This is also pretty %% much the inverse behaviour of our own tx_rollback/2 which is %% why we're not using that. - Cancel = - [ MsgId || #basic_message { is_persistent = IsPersistent, - guid = MsgId } <- TxnMessages, + Cancel = [ MsgId || #basic_message { is_persistent = IsPersistent, + guid = MsgId } <- TxnMessages, not (IsDurable andalso IsPersistent) ], ok = case Cancel of [] -> ok; |