diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-08-19 15:33:24 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-08-19 15:33:24 +0100 |
| commit | a34e13465725855a8707a8897a12088ec49d1a29 (patch) | |
| tree | 3b9823826a311a300be9fe1ff5085121956480f8 /src/rabbit_amqqueue_sup.erl | |
| parent | 640fc3b30d9044e94b8466f233b58fe9dd5876cd (diff) | |
| download | rabbitmq-server-a34e13465725855a8707a8897a12088ec49d1a29.tar.gz | |
Another copy of the master_in_recovery check. Not sure that's very elegant, but I don't think we have much choice.
Diffstat (limited to 'src/rabbit_amqqueue_sup.erl')
| -rw-r--r-- | src/rabbit_amqqueue_sup.erl | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/rabbit_amqqueue_sup.erl b/src/rabbit_amqqueue_sup.erl index 149014e8..8b6fcc01 100644 --- a/src/rabbit_amqqueue_sup.erl +++ b/src/rabbit_amqqueue_sup.erl @@ -18,7 +18,7 @@ -behaviour(supervisor2). --export([start_link/0, start_queue_process/2]). +-export([start_link/0, start_queue_process/3]). -export([init/1]). @@ -31,7 +31,8 @@ -ifdef(use_specs). -spec(start_link/0 :: () -> rabbit_types:ok_pid_or_error()). --spec(start_queue_process/2 :: (node(), rabbit_types:amqqueue()) -> pid()). +-spec(start_queue_process/3 :: (node(), rabbit_types:amqqueue(), + 'declare' | 'recovery' | 'slave') -> pid()). -endif. @@ -40,8 +41,8 @@ start_link() -> supervisor2:start_link({local, ?SERVER}, ?MODULE, []). -start_queue_process(Node, Q) -> - {ok, Pid} = supervisor2:start_child({?SERVER, Node}, [Q]), +start_queue_process(Node, Q, Hint) -> + {ok, Pid} = supervisor2:start_child({?SERVER, Node}, [Q, Hint]), Pid. init([]) -> |