summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@rabbitmq.com>2011-08-22 12:56:10 +0100
committerMatthew Sackman <matthew@rabbitmq.com>2011-08-22 12:56:10 +0100
commit36acaf540745ac666fa3b5b95785a05f8dd3df44 (patch)
tree60a25a2c825ecfad20bedf3ef0be9edaa305ae45
parent54e610e3ee5af75dc3c853f11a2dcc03e64e5c2f (diff)
downloadrabbitmq-server-bug24298.tar.gz
Minor refactorbug24298
-rw-r--r--src/rabbit_variable_queue.erl6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl
index 41f8f736..78d26c51 100644
--- a/src/rabbit_variable_queue.erl
+++ b/src/rabbit_variable_queue.erl
@@ -411,9 +411,9 @@ init(#amqqueue { name = QueueName, durable = true }, true,
AsyncCallback, MsgOnDiskFun, MsgIdxOnDiskFun) ->
Terms = rabbit_queue_index:shutdown_terms(QueueName),
{PRef, Terms1} =
- case [persistent_ref] -- proplists:get_keys(Terms) of
- [] -> {proplists:get_value(persistent_ref, Terms), Terms};
- _ -> {rabbit_guid:guid(), []}
+ case proplists:get_value(persistent_ref, Terms) of
+ undefined -> {rabbit_guid:guid(), []};
+ PRef1 -> {PRef1, Terms}
end,
PersistentClient = msg_store_client_init(?PERSISTENT_MSG_STORE, PRef,
MsgOnDiskFun, AsyncCallback),