diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2010-07-18 14:29:29 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-07-18 14:29:29 +0100 |
| commit | c094929eb41935924f01581d818850ca065ee92c (patch) | |
| tree | 96e4ff51f638dd20161b459ff89888dc6e548299 /src | |
| parent | b8e189feabbb0505125a9d03488c7c3afacde7bf (diff) | |
| download | rabbitmq-server-git-c094929eb41935924f01581d818850ca065ee92c.tar.gz | |
tiny refactor
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index d7116ba041..35a6ff7825 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -308,14 +308,13 @@ start(DurableQueues) -> Refs, StartFunState]). init(QueueName, IsDurable, _Recover) -> - MsgStoreRecovered = - rabbit_msg_store:successfully_recovered_state(?PERSISTENT_MSG_STORE), - ContainsCheckFun = - fun (Guid) -> - rabbit_msg_store:contains(?PERSISTENT_MSG_STORE, Guid) - end, {DeltaCount, Terms, IndexState} = - rabbit_queue_index:init(QueueName, MsgStoreRecovered, ContainsCheckFun), + rabbit_queue_index:init( + QueueName, + rabbit_msg_store:successfully_recovered_state(?PERSISTENT_MSG_STORE), + fun (Guid) -> + rabbit_msg_store:contains(?PERSISTENT_MSG_STORE, Guid) + end), {LowSeqId, NextSeqId, IndexState1} = rabbit_queue_index:bounds(IndexState), {PRef, TRef, Terms1} = |