diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-12-10 11:34:29 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-12-10 11:34:29 +0000 |
| commit | b5224659d3efcee5ba57b1dc4897a91595db7e4a (patch) | |
| tree | f11706d9844a30f6c0f77ed34c6638478574dd2c /src/rabbit_connection_helper_sup.erl | |
| parent | 2f797f1991a6e98cad4a0a85a9580d71542b4858 (diff) | |
| download | rabbitmq-server-b5224659d3efcee5ba57b1dc4897a91595db7e4a.tar.gz | |
A bit more abstraction, plus identities for heartbeater /
queue_collector / limiter.
Diffstat (limited to 'src/rabbit_connection_helper_sup.erl')
| -rw-r--r-- | src/rabbit_connection_helper_sup.erl | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/rabbit_connection_helper_sup.erl b/src/rabbit_connection_helper_sup.erl index e51615e8..a9578748 100644 --- a/src/rabbit_connection_helper_sup.erl +++ b/src/rabbit_connection_helper_sup.erl @@ -20,7 +20,7 @@ -export([start_link/0]). -export([start_channel_sup_sup/1, - start_queue_collector/1]). + start_queue_collector/2]). -export([init/1]). @@ -31,7 +31,8 @@ -ifdef(use_specs). -spec(start_link/0 :: () -> rabbit_types:ok_pid_or_error()). -spec(start_channel_sup_sup/1 :: (pid()) -> rabbit_types:ok_pid_or_error()). --spec(start_queue_collector/1 :: (pid()) -> rabbit_types:ok_pid_or_error()). +-spec(start_queue_collector/2 :: (pid(), rabbit_types:identity()) -> + rabbit_types:ok_pid_or_error()). -endif. %%---------------------------------------------------------------------------- @@ -45,10 +46,10 @@ start_channel_sup_sup(SupPid) -> {channel_sup_sup, {rabbit_channel_sup_sup, start_link, []}, intrinsic, infinity, supervisor, [rabbit_channel_sup_sup]}). -start_queue_collector(SupPid) -> +start_queue_collector(SupPid, Identity) -> supervisor2:start_child( SupPid, - {collector, {rabbit_queue_collector, start_link, []}, + {collector, {rabbit_queue_collector, start_link, [Identity]}, intrinsic, ?MAX_WAIT, worker, [rabbit_queue_collector]}). %%---------------------------------------------------------------------------- |