From 53792a1fa06a79481ddb57aca1bc8ee520f0d346 Mon Sep 17 00:00:00 2001 From: Daniel Schreiber Date: Thu, 2 Jul 2020 09:50:13 +0200 Subject: [PATCH] pika api cahnges --- webtrigger/management/commands/webtriggerdaemon.py | 2 +- webtrigger/queue_tools.py | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/webtrigger/management/commands/webtriggerdaemon.py b/webtrigger/management/commands/webtriggerdaemon.py index 5ac8e37..57ba972 100644 --- a/webtrigger/management/commands/webtriggerdaemon.py +++ b/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() diff --git a/webtrigger/queue_tools.py b/webtrigger/queue_tools.py index a562464..8768d2d 100644 --- a/webtrigger/queue_tools.py +++ b/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() -- GitLab