diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-12-05 16:18:53 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-12-05 16:18:53 +0000 |
| commit | 446d047189f2afbcfce12ad5eb6f1752399cd448 (patch) | |
| tree | 6e7d279f52f505378d9dd0f89257ae483dd88f7b | |
| parent | 86390699256678a58225ace70b8779e242a25d70 (diff) | |
| download | rabbitmq-server-446d047189f2afbcfce12ad5eb6f1752399cd448.tar.gz | |
Don't recover transient messages.
| -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, |