From fad5e800e9a8d53f535f14a2a7e120be597020dd Mon Sep 17 00:00:00 2001 From: Surabhi Date: Wed, 22 Dec 2021 12:12:19 +0530 Subject: [PATCH] removed listener for campaign - not beingused --- .../java/com/uci/orchestrator/Consumer/CampaignConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/uci/orchestrator/Consumer/CampaignConsumer.java b/src/main/java/com/uci/orchestrator/Consumer/CampaignConsumer.java index b79afeb..6c2b055 100644 --- a/src/main/java/com/uci/orchestrator/Consumer/CampaignConsumer.java +++ b/src/main/java/com/uci/orchestrator/Consumer/CampaignConsumer.java @@ -33,7 +33,7 @@ public class CampaignConsumer { @Autowired private CampaignService campaignService; - @KafkaListener(id = "${campaign}", topics = "${campaign}") +// @KafkaListener(id = "${campaign}", topics = "${campaign}") public void consumeMessage(String campaignID) throws Exception { log.info("CampaignID {}", campaignID); processMessage(campaignID)