diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-12-03 17:38:49 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-12-03 17:38:49 +0000 |
| commit | da01d7b96dc5ea124b40b3b00987105318276b0c (patch) | |
| tree | dc8287e5f6ef7826edcf2eb54a7950603af56900 | |
| parent | a3585cc54306096fabd7081d6ee714beafffdf85 (diff) | |
| download | rabbitmq-server-git-da01d7b96dc5ea124b40b3b00987105318276b0c.tar.gz | |
Fix dirty recovery.
| -rw-r--r-- | src/rabbit_variable_queue.erl | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index d63378eb97..c703d3b934 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -455,7 +455,11 @@ init(#amqqueue { name = QueueName, durable = IsDurable }, Terms, case IsDurable of true -> C = msg_store_client_init(?PERSISTENT_MSG_STORE, PRef, MsgOnDiskFun, AsyncCallback), - {C, fun (MId) -> rabbit_msg_store:contains(MId, C) end}; + {C, fun (MsgId) when is_binary(MsgId) -> + rabbit_msg_store:contains(MsgId, C); + (#basic_message{}) -> + true + end}; false -> {undefined, fun(_MsgId) -> false end} end, TransientClient = msg_store_client_init(?TRANSIENT_MSG_STORE, |