Merge pull request #20 from surabhi-mahawar/release-4.4.0

Removed kafka listener for campaign
samagra-comms · Dec 22, 2021 · ffc0dc8 · ffc0dc8
2 parents 26f58c5 + fad5e80
commit ffc0dc8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)