diff options
| author | Ayanda Dube <ayanda.dube@erlang-solutions.com> | 2015-09-25 09:57:57 +0100 |
|---|---|---|
| committer | Ayanda Dube <ayanda.dube@erlang-solutions.com> | 2015-10-07 08:46:41 +0100 |
| commit | aaf06adf5509dd4b10367fb6c782548ecf7101d6 (patch) | |
| tree | 99bb221a1dd1c66bfb7680bd0d3a31f2ac99987b /src | |
| parent | 829ce0d0cb8b1e217036eea98648a2b1c125f8b7 (diff) | |
| download | rabbitmq-server-git-aaf06adf5509dd4b10367fb6c782548ecf7101d6.tar.gz | |
Updates consumers_all/3 to get consumer info in seperate function.
References #62
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 498579ce02..4fe57699dc 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -612,7 +612,7 @@ consumers(#amqqueue{ pid = QPid }) -> delegate:call(QPid, consumers). consumer_info_keys() -> ?CONSUMER_INFO_KEYS. consumers_all(VHostPath) -> - ConsumerInfoKeys=consumer_info_keys(), + ConsumerInfoKeys = consumer_info_keys(), lists:append( map(list(VHostPath), fun (Q) -> @@ -623,20 +623,20 @@ consumers_all(VHostPath) -> end)). consumers_all(VHostPath, Ref, AggregatorPid) -> - ConsumerInfoKeys=consumer_info_keys(), + ConsumerInfoKeys = consumer_info_keys(), map(list(VHostPath), - fun (Q) -> - AggregatorPid ! - {Ref, [lists:zip( - ConsumerInfoKeys, - [Q#amqqueue.name, ChPid, CTag, - AckRequired, Prefetch, Args]) || - {ChPid, CTag, AckRequired, Prefetch, Args} - <- consumers(Q)]} + fun (Q) -> AggregatorPid ! + {Ref, get_queue_consumer_info(Q, ConsumerInfoKeys)} end), AggregatorPid ! {Ref, finished}, ok. +get_queue_consumer_info(Q, ConsumerInfoKeys) -> + lists:flatten([lists:zip(ConsumerInfoKeys, + [Q#amqqueue.name, ChPid, CTag, + AckRequired, Prefetch, Args]) || + {ChPid, CTag, AckRequired, Prefetch, Args} <- consumers(Q)]). + stat(#amqqueue{pid = QPid}) -> delegate:call(QPid, stat). delete_immediately(QPids) -> |