diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-10-26 12:58:10 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-10-26 12:58:10 +0100 |
| commit | 53f291c541b355e40a8bec86724b6523ad629eb6 (patch) | |
| tree | 869bcaef1886fb0575f791dbc56effed50549ac5 | |
| parent | d6ac904a94001f41057b10c1ebbe50361181d846 (diff) | |
| download | rabbitmq-server-git-53f291c541b355e40a8bec86724b6523ad629eb6.tar.gz | |
whitespace
| -rw-r--r-- | src/rabbit_queue_index.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_variable_queue.erl | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index e7f7fa1902..28d0b47dd6 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -244,7 +244,7 @@ shutdown_terms(Name) -> {error, _} -> []; {ok, Terms1} -> Terms1 end. - + recover(Name, Terms, MsgStoreRecovered, ContainsCheckFun) -> State = #qistate { dir = Dir } = blank_state(Name), CleanShutdown = detect_clean_shutdown(Dir), diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 7ac6ea9980..ce0d695642 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -396,7 +396,7 @@ init(QueueName, true, true) -> rabbit_queue_index:recover( QueueName, Terms, rabbit_msg_store:successfully_recovered_state(?PERSISTENT_MSG_STORE), - fun (Guid) -> + fun (Guid) -> rabbit_msg_store:contains(Guid, PersistentClient) end), init(true, IndexState, DeltaCount, Terms1, |