diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-05-16 15:22:46 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-05-16 15:22:46 +0100 |
| commit | 36dddc9143f67136fa536c569123796d3ca23a3e (patch) | |
| tree | e3181150d5162ea2d29bc03e0b96a2452d6ef847 | |
| parent | d0652f278fc17ed260738b51d6f49a0598d0dd2f (diff) | |
| download | rabbitmq-server-git-36dddc9143f67136fa536c569123796d3ca23a3e.tar.gz | |
get a node to clean up after old incarnations of itself
...in case other nodes don't do so in time or, if they themselves
stop/restart, ever.
| -rw-r--r-- | src/rabbit_amqqueue.erl | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index c1673504e7..c774757104 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -166,6 +166,7 @@ [queue_name, channel_pid, consumer_tag, ack_required]). start() -> + on_node_down(node()), %% clear out remnants of old incarnation DurableQueues = find_durable_queues(), {ok, BQ} = application:get_env(rabbit, backing_queue_module), ok = BQ:start([QName || #amqqueue{name = QName} <- DurableQueues]), |