Count queue messages in a broker
No One
Actions

Authored By

	dereckson
	Jul 5 2017, 22:35

Size

403 B

Referenced Files

None

Subscribers

None

Count queue messages in a broker
View Options

	def count_queue_messages(queue_name):
	connection = get_broker_connection(service['config'])
	channel = connection.channel()
	result = channel.queue_declare(durable=True,
	queue=queue_name,
	passive=True)
	return result.method.message_count


	def is_queue_empty(queue_name):
	return count_queue_messages(queue_name) == 0

File Metadata

Mime Type: text/plain; charset=utf-8
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 112492
Default Alt Text: Count queue messages in a broker (403 B)

Event Timeline