pika api cahnges

webtrigger/management/commands/webtriggerdaemon.py

@@ -63,5 +63,5 @@ class Command(BaseCommand):
 
         channel, exchange, queues = setup_queue()
         channel.basic_qos(prefetch_count=1)
-        channel.basic_consume(callback, queue=options['queue_name'])
+        channel.basic_consume(on_message_callback=callback, queue=options['queue_name'])
         channel.start_consuming()

webtrigger/queue_tools.py

@@ -33,8 +33,8 @@ def setup_queue_with_deadletter(channel, name, delay_ttl=(30 * 60 * 1000)):
     exchange_cycle = '{}-cycle'.format(exchange_name)
     delay_queue = '{}-delay'.format(name)
     # deadletter
-    channel.exchange_declare(exchange=exchange_cycle, type='fanout', durable=True)
-    channel.exchange_declare(exchange=exchange_name, type='fanout', durable=True)
+    channel.exchange_declare(exchange=exchange_cycle, exchange_type='fanout', durable=True)
+    channel.exchange_declare(exchange=exchange_name, exchange_type='fanout', durable=True)
     channel.queue_declare(
         queue=delay_queue, durable=True, arguments={
             'x-message-ttl': delay_ttl,
@@ -75,5 +75,5 @@ def remove_event_from_deadletter(event, uuid, queue, max_tries=10):
             channel.stop_consuming()
 
     channel.basic_qos(prefetch_count=1)
-    channel.basic_consume(callback, queue=queue)
+    channel.basic_consume(on_message_callback=callback, queue=queue)
     channel.start_consuming()