diff options
author | Matthias Radestock <matthias@rabbitmq.com> | 2014-01-15 19:14:23 +0000 |
---|---|---|
committer | Matthias Radestock <matthias@rabbitmq.com> | 2014-01-15 19:14:23 +0000 |
commit | ce9844cff300a2b50f3e046a62a96a34c6d6911b (patch) | |
tree | 20ff29503137a48b2057eb066099e436e4587496 | |
parent | af00f09c66d5db546e3e59adafdf86ba5230ec1d (diff) | |
download | rabbitmq-server-ce9844cff300a2b50f3e046a62a96a34c6d6911b.tar.gz |
cosmetic
-rw-r--r-- | src/rabbit_queue_index.erl | 3 | ||||
-rw-r--r-- | src/rabbit_variable_queue.erl | 2 |
2 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 292ad983..e2d3c40d 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -233,8 +233,7 @@ init(Name, OnSyncFun) -> false = rabbit_file:is_file(Dir), %% is_file == is file or dir State #qistate { on_sync = OnSyncFun }. -recover(Name, Terms, MsgStoreRecovered, - ContainsCheckFun, OnSyncFun) -> +recover(Name, Terms, MsgStoreRecovered, ContainsCheckFun, OnSyncFun) -> State = blank_state(Name), State1 = State #qistate { on_sync = OnSyncFun }, CleanShutdown = Terms /= non_clean_shutdown, diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 58647d3b..a5dc5df4 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -455,7 +455,7 @@ process_recovery_terms(Terms=non_clean_shutdown) -> process_recovery_terms(Terms) -> case proplists:get_value(persistent_ref, Terms) of undefined -> {rabbit_guid:gen(), []}; - PRef1 -> {PRef1, Terms} + PRef -> {PRef, Terms} end. terminate(_Reason, State) -> |