diff options
| author | Diana Corbacho <diana.corbacho@erlang-solutions.com> | 2016-06-21 08:20:37 +0100 |
|---|---|---|
| committer | Diana Corbacho <diana.corbacho@erlang-solutions.com> | 2016-06-22 16:03:24 +0100 |
| commit | 716a43bbd34786b5052b2ca4f2b46e6516958aa0 (patch) | |
| tree | 64e915e3fb4da23b84c9022e8edc1cdbad81b178 /src | |
| parent | 5f1ffc6b2834aca32674121ed723e6b7e632a54e (diff) | |
| download | rabbitmq-server-git-716a43bbd34786b5052b2ca4f2b46e6516958aa0.tar.gz | |
Erase index on crash recovery for any backing queue
It is up to the individual implementation to decide what to erase,
i.e. priority queues have one index per priority
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 9edb99c4d7..c04c82f45e 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -120,7 +120,7 @@ handle_go(Q = #amqqueue{name = QName}) -> Self, {rabbit_amqqueue, set_ram_duration_target, [Self]}), {ok, BQ} = application:get_env(backing_queue_module), Q1 = Q #amqqueue { pid = QPid }, - ok = rabbit_queue_index:erase(QName), %% For crash recovery + _ = BQ:delete_crashed(Q), %% For crash recovery BQS = bq_init(BQ, Q1, new), State = #state { q = Q1, gm = GM, |