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
commitc323222284af3526b69d27f7a37fd59f060006fd (patch)
tree60a25a2c825ecfad20bedf3ef0be9edaa305ae45
parent46d94f46c372df11f3e728521a137d00efaf7992 (diff)
downloadrabbitmq-server-git-c323222284af3526b69d27f7a37fd59f060006fd.tar.gz
Minor refactor
-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 41f8f73697..78d26c510e 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),