From 4fbb015d791455419cd9b641332852cf50b64f63 Mon Sep 17 00:00:00 2001 From: sriram veeraghanta Date: Tue, 27 Aug 2024 16:07:02 +0530 Subject: [PATCH] fix:adding mq configuration and testing message passing --- apiserver/plane/bgtasks/notifier/__init__.py | 1 + apiserver/plane/bgtasks/notifier/issue.py | 23 ++++++++++++++++++++ 2 files changed, 24 insertions(+) create mode 100644 apiserver/plane/bgtasks/notifier/__init__.py create mode 100644 apiserver/plane/bgtasks/notifier/issue.py diff --git a/apiserver/plane/bgtasks/notifier/__init__.py b/apiserver/plane/bgtasks/notifier/__init__.py new file mode 100644 index 0000000000..72c85b0a1c --- /dev/null +++ b/apiserver/plane/bgtasks/notifier/__init__.py @@ -0,0 +1 @@ +from .issue import notify_issue_activity \ No newline at end of file diff --git a/apiserver/plane/bgtasks/notifier/issue.py b/apiserver/plane/bgtasks/notifier/issue.py new file mode 100644 index 0000000000..f61d0fd95b --- /dev/null +++ b/apiserver/plane/bgtasks/notifier/issue.py @@ -0,0 +1,23 @@ +import pika +from django.conf import settings +from celery import shared_task + + +def publish_issue_activity(queue_name, message): + # print(settings.CELERY_BROKER_URL) + connection = pika.BlockingConnection( + pika.ConnectionParameters("127.0.0.1") + ) + channel = connection.channel() + channel.queue_declare(queue=queue_name, durable=True) + channel.basic_publish(exchange="", routing_key=queue_name, body=message) + connection.close() + + +@shared_task +def notify_issue_activity(queue_name, message): + publish_issue_activity(queue_name, message) + + +if __name__ == "__main__": + publish_issue_activity("NOTIFY_ISSUE_ACTIVITY", "Hello World")