D335.diff
No OneTemporary
Actions

Size

437 B

Referenced Files

None

Subscribers

None

D335.diff
View Options

	diff --git a/notifications b/notifications
	--- a/notifications
	+++ b/notifications
	@@ -60,7 +60,7 @@

	def get_broker_queue(channel, exchange):
	"""Ensure exchange exists and declare a temporary queue."""
	- channel.exchange_declare(exchange=exchange, type='topic')
	+ channel.exchange_declare(exchange=exchange, type='topic', durable=True)
	result = channel.queue_declare(exclusive=True)
	return result.method.queue