D2361.diff
No OneTemporary
Actions

Size

829 B

Referenced Files

None

Subscribers

None

D2361.diff
View Options

	diff --git a/notifications b/notifications
	--- a/notifications
	+++ b/notifications
	@@ -62,7 +62,7 @@
	"""Ensure exchange exists and declare a temporary queue."""
	channel.exchange_declare(
	exchange=exchange, exchange_type='topic', durable=True)
	- result = channel.queue_declare(exclusive=True)
	+ result = channel.queue_declare("", exclusive=True)
	return result.method.queue


	@@ -190,7 +190,7 @@
	"""Consume notifications from a queue
	and call our callback method when a message is received.
	"""
	- channel.basic_consume(on_broker_message, queue=queue)
	+ channel.basic_consume(queue, on_broker_message)
	channel.start_consuming()


	diff --git a/requirements.txt b/requirements.txt
	new file mode 100644
	--- /dev/null
	+++ b/requirements.txt
	@@ -0,0 +1 @@
	+pika<2.0.0,>=1.1.0