diff options
| author | Ayanda Dube <ayanda.dube@erlang-solutions.com> | 2015-09-14 17:31:07 +0100 |
|---|---|---|
| committer | Ayanda Dube <ayanda.dube@erlang-solutions.com> | 2015-10-07 08:46:41 +0100 |
| commit | 829ce0d0cb8b1e217036eea98648a2b1c125f8b7 (patch) | |
| tree | 8d6cc1d63a397fc4ae716a88ef230924c601696f /src | |
| parent | d5d2c7dbdab5738f2d25f4ca0dce2be35b761339 (diff) | |
| download | rabbitmq-server-git-829ce0d0cb8b1e217036eea98648a2b1c125f8b7.tar.gz | |
Removes append operation on result list.
References #62
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 21 |
1 files changed, 10 insertions, 11 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index cba083bea1..498579ce02 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -624,17 +624,16 @@ consumers_all(VHostPath) -> consumers_all(VHostPath, Ref, AggregatorPid) -> ConsumerInfoKeys=consumer_info_keys(), - lists:append( - 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)]} - end)), + 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)]} + end), AggregatorPid ! {Ref, finished}, ok. |