diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2011-05-31 10:58:20 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2011-05-31 10:58:20 +0100 |
| commit | 97f0be9123efe4c40a2ae2e5e2bcc04f7635f1f5 (patch) | |
| tree | 9c95a4c8737c47da1dea6910760c009a10a008da /src/rabbit_amqqueue.erl | |
| parent | f669d257d056228becc58f1603190cfa8a619bb3 (diff) | |
| download | rabbitmq-server-97f0be9123efe4c40a2ae2e5e2bcc04f7635f1f5.tar.gz | |
Optimisation while listing consumers
Diffstat (limited to 'src/rabbit_amqqueue.erl')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 023eef49..f9ed3edc 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -348,10 +348,11 @@ consumers(#amqqueue{ pid = QPid }) -> consumer_info_keys() -> ?CONSUMER_INFO_KEYS. consumers_all(VHostPath) -> + ConsumerInfoKeys=consumer_info_keys(), lists:append( map(VHostPath, fun (Q) -> - [lists:zip(consumer_info_keys(), + [lists:zip(ConsumerInfoKeys, [Q#amqqueue.name, ChPid, ConsumerTag, AckRequired]) || {ChPid, ConsumerTag, AckRequired} <- consumers(Q)] end)). |