diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-08-26 23:15:13 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-08-26 23:15:13 +0100 |
| commit | 793f87097ab7c60ceaa955b362fc113b7e4b392a (patch) | |
| tree | 781db8bcd37f6f378d709ede39bd83628a5e120e | |
| parent | 2b6981ae3384b61882acb4ac49c4822153067b87 (diff) | |
| download | rabbitmq-server-git-793f87097ab7c60ceaa955b362fc113b7e4b392a.tar.gz | |
cosmetic
| -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; |