From fbb0c277b387f0379cbd79b41cbea9c1968045ee Mon Sep 17 00:00:00 2001 From: hong seokho Date: Tue, 13 Aug 2024 00:14:58 +0900 Subject: [PATCH] =?UTF-8?q?fix=20:=20=EB=A9=94=EC=8B=9C=EC=A7=80=20?= =?UTF-8?q?=EC=A0=84=EC=86=A1=20=EB=A7=88=EB=8B=A4=20=ED=81=90=20=EC=84=A0?= =?UTF-8?q?=EC=96=B8=20=ED=99=95=EC=9D=B8=20=EC=82=AD=EC=A0=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 메시지 전송 마다 큐 선언과 옵션 확인으로 인한 오류로 인한 수정 --- backend/AnimatedDrawings/application/task/base_task.py | 5 ----- backend/AnimatedDrawings/application/task/tasks.py | 5 ----- 2 files changed, 10 deletions(-) diff --git a/backend/AnimatedDrawings/application/task/base_task.py b/backend/AnimatedDrawings/application/task/base_task.py index eedcb74b..7ecf18fb 100644 --- a/backend/AnimatedDrawings/application/task/base_task.py +++ b/backend/AnimatedDrawings/application/task/base_task.py @@ -44,13 +44,8 @@ def on_failure(self, exc, task_id, args, kwargs, einfo): type='direct', durable=True) - notification_queue = Queue(name=QueueConfig.NOTIFICATION_QUEUE_NAME, - exchange=notification_exchange, - routing_key=QueueConfig.NOTIFICATION_QUEUE_NAME) - producer.publish( request_data, - declare=[notification_queue], exchange=notification_exchange, content_type='application/json', routing_key=QueueConfig.NOTIFICATION_QUEUE_NAME, diff --git a/backend/AnimatedDrawings/application/task/tasks.py b/backend/AnimatedDrawings/application/task/tasks.py index 3c6cc79f..9d760383 100644 --- a/backend/AnimatedDrawings/application/task/tasks.py +++ b/backend/AnimatedDrawings/application/task/tasks.py @@ -119,13 +119,8 @@ def send_notification(self, _, input_data: dict, filename: str): type='direct', durable=True) - queue = Queue(name=QueueConfig.NOTIFICATION_QUEUE_NAME, - exchange=exchange, - routing_key=QueueConfig.NOTIFICATION_QUEUE_NAME) - producer.publish( request_data, - declare=[queue], exchange=exchange, content_type='application/json', routing_key=QueueConfig.NOTIFICATION_QUEUE_NAME,