diff options
| -rw-r--r-- | src/delegate.erl | 6 | ||||
| -rw-r--r-- | src/rabbit_amqqueue_sup.erl | 11 |
2 files changed, 14 insertions, 3 deletions
diff --git a/src/delegate.erl b/src/delegate.erl index 17046201ad..edb4eba4ae 100644 --- a/src/delegate.erl +++ b/src/delegate.erl @@ -28,13 +28,13 @@ -ifdef(use_specs). -spec(start_link/1 :: - (non_neg_integer()) -> {'ok', pid()} | {'error', any()}). --spec(invoke_no_result/2 :: - (pid() | [pid()], fun ((pid()) -> any())) -> 'ok'). + (non_neg_integer()) -> {'ok', pid()} | ignore | {'error', any()}). -spec(invoke/2 :: ( pid(), fun ((pid()) -> A)) -> A; ([pid()], fun ((pid()) -> A)) -> {[{pid(), A}], [{pid(), term()}]}). +-spec(invoke_no_result/2 :: + (pid() | [pid()], fun ((pid()) -> any())) -> 'ok'). -endif. diff --git a/src/rabbit_amqqueue_sup.erl b/src/rabbit_amqqueue_sup.erl index 2c28adcefd..c70d6f560d 100644 --- a/src/rabbit_amqqueue_sup.erl +++ b/src/rabbit_amqqueue_sup.erl @@ -26,6 +26,17 @@ -define(SERVER, ?MODULE). +-ifdef(use_specs). + +-spec(start_link/0 :: + () -> rabbit_types:ok_or_error2(pid(), {already_started, pid()})). +-spec(start_child/2 :: + (node(), [any()]) -> rabbit_types:ok(pid() | undefined) | + rabbit_types:ok({pid(), any()}) | + rabbit_types:error(any())). + +-endif. + start_link() -> supervisor2:start_link({local, ?SERVER}, ?MODULE, []). |