From 2c0e6ec7d75afb10dace6b481b9109e46e70d0d3 Mon Sep 17 00:00:00 2001 From: marcsello Date: Tue, 17 Aug 2021 17:56:52 +0200 Subject: [PATCH] Removed queue as we do not scrubscribe --- src/config.py | 1 - src/magic_amqp.py | 1 - 2 files changed, 2 deletions(-) diff --git a/src/config.py b/src/config.py index 5b7362c..6c6a8ba 100644 --- a/src/config.py +++ b/src/config.py @@ -20,7 +20,6 @@ class Config: RELEASEMODE = os.environ.get("INPUT_SERVICE_RELEASEMODE", "dev") EXCHANGE_NAME = os.getenv("INPUT_RABBITMQ_EXCHANGE", "dev") - RABBITMQ_QUEUE = os.getenv("INPUT_RABBITMQ_QUEUE", "wave-extract") FLASK_PIKA_PARAMS = { 'host': os.getenv("INPUT_RABBITMQ_HOSTNAME", "localhost"), diff --git a/src/magic_amqp.py b/src/magic_amqp.py index f719183..d550aea 100644 --- a/src/magic_amqp.py +++ b/src/magic_amqp.py @@ -27,7 +27,6 @@ class MagicAMQP: self.app = app self.app.config.setdefault('FLASK_PIKA_PARAMS', {}) self.app.config.setdefault('EXCHANGE_NAME', None) - self.app.config.setdefault('RABBITMQ_QUEUE', None) self._credentials = pika.PlainCredentials( app.config['FLASK_PIKA_PARAMS']['username'],