diff options
Diffstat (limited to 'src/rabbit_variable_queue.erl')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 7a7a2900..905ed6be 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -457,8 +457,8 @@ init(#amqqueue { name = QueueName, durable = IsDurable }, Terms, MsgOnDiskFun, AsyncCallback), {C, fun (MsgId) when is_binary(MsgId) -> rabbit_msg_store:contains(MsgId, C); - (#basic_message{}) -> - true + (#basic_message{is_persistent = Persistent}) -> + Persistent end}; false -> {undefined, fun(_MsgId) -> false end} end, |