diff options
| author | Matthias Radestock <matthias@lshift.net> | 2010-04-27 11:02:30 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2010-04-27 11:02:30 +0100 |
| commit | 6550aafab253053c226376752a011d49bf914cee (patch) | |
| tree | e0e083da63eaf148a185714ca76cee9e02060896 /src | |
| parent | 848792f5adb5843d35d4343267169cbe100f406c (diff) | |
| download | rabbitmq-server-git-6550aafab253053c226376752a011d49bf914cee.tar.gz | |
simplification
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_invariable_queue.erl | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/src/rabbit_invariable_queue.erl b/src/rabbit_invariable_queue.erl index 86d80e66fa..30c5744dac 100644 --- a/src/rabbit_invariable_queue.erl +++ b/src/rabbit_invariable_queue.erl @@ -255,12 +255,11 @@ persist_delivery(QName, #basic_message { guid = Guid }, _IsDelivered) -> persist_acks(Txn, QName, AckTags, PA) -> persist_work(Txn, QName, - [{ack, {QName, Guid}} || - Guid <- AckTags, - case dict:find(Guid, PA) of - {ok, #basic_message { is_persistent = true }} -> true; - _ -> false - end]). + [{ack, {QName, Guid}} || Guid <- AckTags, + begin + {ok, Msg} = dict:find(Guid, PA), + Msg #basic_message.is_persistent + end]). persist_work(_Txn,_QName, []) -> ok; |