From c242f662c1ef7ba0d048b0aa4e459c57c82ac2f1 Mon Sep 17 00:00:00 2001 From: AhmadHoseiny Date: Sun, 18 May 2025 23:20:11 +0200 Subject: [PATCH] fix: fix rabbit issue --- .../messaging/AnalyticsRabbitListener.java | 22 +++++++++---------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/src/main/java/com/Podzilla/analytics/messaging/AnalyticsRabbitListener.java b/src/main/java/com/Podzilla/analytics/messaging/AnalyticsRabbitListener.java index 7642c35..5208367 100644 --- a/src/main/java/com/Podzilla/analytics/messaging/AnalyticsRabbitListener.java +++ b/src/main/java/com/Podzilla/analytics/messaging/AnalyticsRabbitListener.java @@ -1,7 +1,7 @@ package com.Podzilla.analytics.messaging; -// import org.springframework.amqp.rabbit.annotation.RabbitListener; -// import com.podzilla.mq.EventsConstants; +import org.springframework.amqp.rabbit.annotation.RabbitListener; +import com.podzilla.mq.EventsConstants; import org.springframework.beans.factory.annotation.Autowired; import com.podzilla.mq.events.BaseEvent; @@ -16,23 +16,23 @@ public class AnalyticsRabbitListener { @Autowired private InvokerDispatcher dispatcher; - // @RabbitListener( - // queues = EventsConstants.ANALYTICS_USER_EVENT_QUEUE - // ) + @RabbitListener( + queues = EventsConstants.ANALYTICS_USER_EVENT_QUEUE + ) public void handleUserEvents(final BaseEvent userEvent) { dispatcher.dispatch(userEvent); } - // @RabbitListener( - // queues = EventsConstants.ANALYTICS_ORDER_EVENT_QUEUE - // ) + @RabbitListener( + queues = EventsConstants.ANALYTICS_ORDER_EVENT_QUEUE + ) public void handleOrderEvents(final BaseEvent orderEvent) { dispatcher.dispatch(orderEvent); } - // @RabbitListener( - // queues = EventsConstants.ANALYTICS_INVENTORY_EVENT_QUEUE - // ) + @RabbitListener( + queues = EventsConstants.ANALYTICS_INVENTORY_EVENT_QUEUE + ) public void handleInventoryEvents(final BaseEvent inventoryEvent) { dispatcher.dispatch(inventoryEvent); }