Pika update
Changes for the latest Pika version:
Connection Parameters
Old: ssl=use_ssl
in pika.ConnectionParameters
New:
context = ssl.create_default_context()
ssl_options = pika.SSLOptions(context, host)
and use ssl_options=ssl_options
Old: heartbeat_interval=heartbeat_interval
New: heartbeat=heartbeat_interval
Queue Declare
Old: channel.queue_declare(durable=1, queue=queue_name, ...)
New: channel.queue_declare(queue_name, durable=True, ...)
Basic consume
Old: channel.basic_consume(wrapper, queue=self.queue_name)
New: channel.basic_consume(self.queue_name, wrapper)
Connection close exception
Old: except pika.exceptions.ConnectionClosed as cc:
New: except pika.exceptions.StreamLostError as cc:
Edited by Stefan-Gabriel Chitic