jira-plat-130

Author: Sachin Maheshwari

.circleci/config.yml

@@ -88,12 +88,12 @@ workflows:
             branches:
               only: 
                 - dev
-                - dev-msinteg
+                - feature/jira-plat-130
                 - dev-ecs
       - "build-prod":
           context : org-global
           filters:
             branches:
               only: 
                 - master
-                - master-ecs
+                - master-ecs

service/src/main/java/com/appirio/service/review/manager/ScoreManager.java

@@ -72,7 +72,11 @@ public ScoreManager() throws SupplyException {
                 ReviewItemDAO.class);
         this.scoreDAO = DAOFactory.getInstance().createDAO(ScoreDAO.class);
         this.projectResultDAO = DAOFactory.getInstance().createDAO(ProjectResultDAO.class);
-        this.eventProducer = EventProducer.getInstance();
+        /**
+            //jira-plat-130, hard cut the legacy publishing
+            this.eventProducer =  EventProducer.getInstance();
+        */
+        this.eventProducer =  null;
     }
 
     /**
@@ -356,7 +360,13 @@ public void updateScores(List<ReviewItem> reviewItems, AuthUser auth) throws Exc
     private void publishKafkaEvent(JsonNode json, String topic) {
         // fire an event on to the kafka bus
         try {
-            eventProducer.publish(topic, json);
+            if (eventProducer != null) {
+		eventProducer.publish(topic, json);
+            } else {
+		// jira-plat-130, hard cut the leagacy kafka
+
+              logger.info("jira-plat-130, hard cut the legacy publishing for topic: " + topic);
+             }
         } catch (EmptyEventException e) {
             logger.info("Failed to publish message " + e.getMessage());
         } catch (EncodingEventException e) {