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 | 89fd8c8a38f254b8fbdb1e53b75f81bed0cd7ba8 (patch) | |
| tree | 6e7d279f52f505378d9dd0f89257ae483dd88f7b /src | |
| parent | 9403fb3c267dd2d62b8eca6b0a17da408c8a083b (diff) | |
| download | rabbitmq-server-git-89fd8c8a38f254b8fbdb1e53b75f81bed0cd7ba8.tar.gz | |
Don't recover transient messages.
Diffstat (limited to 'src')
| -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 7a7a2900e5..905ed6be1f 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, |