From 707598d07001d131b703500e07649fa676a37915 Mon Sep 17 00:00:00 2001 From: Mardone Date: Wed, 17 Apr 2024 15:27:03 -0300 Subject: [PATCH] Send recent activities via eda --- bothub/common/tasks.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/bothub/common/tasks.py b/bothub/common/tasks.py index 02f99f0d..05ce50f0 100644 --- a/bothub/common/tasks.py +++ b/bothub/common/tasks.py @@ -13,6 +13,7 @@ from django_elasticsearch_dsl.registries import registry +from bothub.event_driven.publisher.rabbitmq_publisher import RabbitMQPublisher from bothub import translate from bothub.celery import app from bothub.common.models import ( @@ -688,5 +689,10 @@ def create_repository_project(**kwargs): @app.task(name="send_recent_activity") def send_recent_activity(recent_activity_data): - connect_client = ConnectClient() - connect_client.create_recent_activity(recent_activity_data=recent_activity_data) + rabbitmq_publisher = RabbitMQPublisher() + rabbitmq_publisher.send_message( + body=recent_activity_data, + exchange="recent-activities.topic", + routing_key="", + ) + print(f"[ intelligencePublisher ] message sent - {recent_activity_data} to recent-activities.topic")