diff options
author | Matthew Sackman <matthew@rabbitmq.com> | 2011-07-26 18:39:12 +0100 |
---|---|---|
committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-07-26 18:39:12 +0100 |
commit | a3bc422fa3e94686025d651f9326bb90c46f5158 (patch) | |
tree | 625444aceab58a7b03a09081f02f1b80b5721c7f /src/rabbit_amqqueue.erl | |
parent | 9433b14ae3f0e864895b0b02837b7598cadfe32c (diff) | |
download | rabbitmq-server-a3bc422fa3e94686025d651f9326bb90c46f5158.tar.gz |
Wipe out slave pids whenever we start up a queue.
Diffstat (limited to 'src/rabbit_amqqueue.erl')
-rw-r--r-- | src/rabbit_amqqueue.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index e9d01d12..d6e10471 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -254,7 +254,8 @@ determine_queue_nodes(Args) -> end. start_queue_process(Node, Q) -> - {ok, Pid} = rabbit_amqqueue_sup:start_child(Node, [Q]), + {ok, Pid} = rabbit_amqqueue_sup:start_child(Node, + [Q#amqqueue{slave_pids = []}]), Q#amqqueue{pid = Pid}. add_default_binding(#amqqueue{name = QueueName}) -> |