Congegni/sintonia
7
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Set pika version to ~1.1.0 to prevent api updates from breaking code.

Browse source 
Updated message_listener for new version.
This commit is contained in:
Keoni Mahelona 2020-03-04 15:16:14 +13:00 • committed by Kyle Robbertze
parent 4a45225369
commit a643883d06
2 changed files with 2 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

3
python_apps/airtime_analyzer/airtime_analyzer/message_listener.py
View file

@ -112,8 +112,7 @@ class MessageListener:
self._channel.queue_bind(exchange=EXCHANGE, queue=QUEUE, routing_key=ROUTING_KEY)
logging.info(" Listening for messages...")
self._channel.basic_consume(self.msg_received_callback,
queue=QUEUE, no_ack=False)
self._channel.basic_consume(QUEUE, self.msg_received_callback, auto_ack=False)
def wait_for_messages(self):
'''Wait until we've received a RabbitMQ message.'''