Skip to content

Commit ec7b46d

Browse files
author
DanielePalaia
committed
adding message/consumer count in QueueInfo
1 parent d734ab3 commit ec7b46d

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

rabbitmq_amqp_python_client/management.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -369,4 +369,6 @@ def queue_info(self, name: str) -> QueueInfo:
369369
leader=queue_info["leader"],
370370
members=queue_info["replicas"],
371371
arguments=queue_info["arguments"],
372+
message_count=queue_info["message_count"],
373+
consumer_count=queue_info["consumer_count"],
372374
)

0 commit comments

Comments
 (0)