diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-06-14 15:25:51 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-06-14 15:25:51 +0100 |
| commit | 1fba8d2de9c6b591a5cad458b9ef3e0d232c0514 (patch) | |
| tree | c91ac7715da8058d54ac90fa7d5b16002bf1dd29 | |
| parent | 93af9aad4ec6f1c77fc2b2d9fa51be2bdcbdfd25 (diff) | |
| download | rabbitmq-server-git-1fba8d2de9c6b591a5cad458b9ef3e0d232c0514.tar.gz | |
Improve comment
| -rw-r--r-- | src/rabbit_amqqueue.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index c774757104..56bff25724 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -166,7 +166,9 @@ [queue_name, channel_pid, consumer_tag, ack_required]). start() -> - on_node_down(node()), %% clear out remnants of old incarnation + %% Clear out remnants of old incarnation, in case we restarted + %% faster than other nodes handled DOWN messages from us. + on_node_down(node()), DurableQueues = find_durable_queues(), {ok, BQ} = application:get_env(rabbit, backing_queue_module), ok = BQ:start([QName || #amqqueue{name = QName} <- DurableQueues]), |