diff options
Diffstat (limited to 'src')
| -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 292ad98321..e2d3c40dc6 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 58647d3b8b..a5dc5df498 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) -> |