diff options
| author | Ayanda Dube <ayanda.dube@erlang-solutions.com> | 2015-09-09 16:15:56 +0100 |
|---|---|---|
| committer | Ayanda Dube <ayanda.dube@erlang-solutions.com> | 2015-10-07 08:46:41 +0100 |
| commit | 7d8af0eea84e60358d951fc24ac5d51713e54f5f (patch) | |
| tree | d26ef7b550bf2dfeb62da0bd970d9bd23664f11a /src | |
| parent | 7049d834d07fd40afac221ccaee91762d2d4a8a3 (diff) | |
| download | rabbitmq-server-git-7d8af0eea84e60358d951fc24ac5d51713e54f5f.tar.gz | |
Updates info_all/4 function spec.
Updates consumers_all/3 function and spec.
References #62
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 997252c371..43ca26e406 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -120,7 +120,7 @@ -spec(info_all/2 :: (rabbit_types:vhost(), rabbit_types:info_keys()) -> [rabbit_types:infos()]). -spec(info_all/4 :: (rabbit_types:vhost(), rabbit_types:info_keys(), - reference()) -> 'ok'). + reference(), pid()) -> 'ok'). -spec(force_event_refresh/1 :: (reference()) -> 'ok'). -spec(notify_policy_changed/1 :: (rabbit_types:amqqueue()) -> 'ok'). -spec(consumers/1 :: (rabbit_types:amqqueue()) @@ -133,8 +133,7 @@ non_neg_integer(), rabbit_framing:amqp_table()}]). -spec(consumers_all/3 :: (rabbit_types:vhost(), reference(), pid()) - -> [{reference(), {name(), pid(), rabbit_types:ctag(), boolean(), - non_neg_integer(), rabbit_framing:amqp_table()}}]). + -> 'ok'). -spec(stat/1 :: (rabbit_types:amqqueue()) -> {'ok', non_neg_integer(), non_neg_integer()}). @@ -633,7 +632,9 @@ consumers_all(VHostPath, Ref, Pid) -> AckRequired, Prefetch, Args]) || {ChPid, CTag, AckRequired, Prefetch, Args} <- consumers(Q)]} - end)). + end)), + Pid ! {Ref, finished}, + ok. stat(#amqqueue{pid = QPid}) -> delegate:call(QPid, stat). |