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: