diff options
| author | Tim Watson <tim@rabbitmq.com> | 2013-12-19 22:18:57 +0000 |
|---|---|---|
| committer | Tim Watson <tim@rabbitmq.com> | 2013-12-19 22:18:57 +0000 |
| commit | 67adf2465cbf852317fd6ade0c0d6892bd1a1850 (patch) | |
| tree | 9e4c6417994fee9cbb1d597b5233d136a5bc3b9f /src | |
| parent | 6e505050521c1f361ef7339c65f586b324c84509 (diff) | |
| download | rabbitmq-server-git-67adf2465cbf852317fd6ade0c0d6892bd1a1850.tar.gz | |
push down recovery index handling into qi recovery
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit.erl | 1 | ||||
| -rw-r--r-- | src/rabbit_queue_index.erl | 1 |
2 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit.erl b/src/rabbit.erl index 0203b4e94c..045c5d587b 100644 --- a/src/rabbit.erl +++ b/src/rabbit.erl @@ -595,7 +595,6 @@ boot_delegate() -> recover() -> rabbit_policy:recover(), - ok = rabbit_recovery_terms:recover(), Qs = rabbit_amqqueue:recover(), ok = rabbit_binding:recover(rabbit_exchange:recover(), [QName || #amqqueue{name = QName} <- Qs]), diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 03c9db502c..03d248e096 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -362,6 +362,7 @@ bounds(State = #qistate { segments = Segments }) -> {LowSeqId, NextSeqId, State}. recover(DurableQueues) -> + rabbit_recovery_terms:recover(), DurableDict = dict:from_list( [ begin |