diff options
| -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; |