diff options
Diffstat (limited to 'src/rabbit_amqqueue.erl')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 10f97afd..0673ff8e 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -184,7 +184,7 @@ %%---------------------------------------------------------------------------- -define(CONSUMER_INFO_KEYS, - [queue_name, channel_pid, consumer_tag, ack_required]). + [queue_name, channel_pid, consumer_tag, ack_required, arguments]). recover() -> %% Clear out remnants of old incarnation, in case we restarted @@ -512,8 +512,8 @@ consumers_all(VHostPath) -> map(VHostPath, fun (Q) -> [lists:zip(ConsumerInfoKeys, - [Q#amqqueue.name, ChPid, ConsumerTag, AckRequired]) || - {ChPid, ConsumerTag, AckRequired} <- consumers(Q)] + [Q#amqqueue.name, ChPid, CTag, AckRequired, Args]) || + {ChPid, CTag, AckRequired, Args} <- consumers(Q)] end)). stat(#amqqueue{pid = QPid}) -> delegate:call(QPid, stat). |