gdrs

akrosinc · Oct 14, 2024 · 3b5ef7c · 3b5ef7c
1 parent 44791f6
commit 3b5ef7c
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/...main/java/com/revealprecision/revealserver/messaging/listener/HdssProcessingListener.java b/...main/java/com/revealprecision/revealserver/messaging/listener/HdssProcessingListener.java
@@ -115,6 +115,8 @@ public void etl(EventTrackerMessage eventTrackerMessage) {
 
             UUID targetPlan = hdssProperties.getTarget().get(planIdentifier1);
 
+            log.info("Target plan {}", targetPlan);
+
             if (targetPlan != null) {
 
               sendEmails(individual, indexStructure, indexHousehold, compoundId,
@@ -130,14 +132,19 @@ public void etl(EventTrackerMessage eventTrackerMessage) {
                   .collect(
                       Collectors.toList());
 
+
+              log.info("submitting index case  {}", indexStructure);
               submitTasks(owner, List.of(indexStructure), targetPlan, actions,
                   ActionTitleEnum.INDEX_CASE);
 
+              log.info("submitting index case members {}", indexIndividual.getId());
               submitTasks(owner, List.of(UUID.fromString(indexIndividual.getId())), targetPlan, actions,
                   ActionTitleEnum.INDEX_CASE_MEMBER);
 
+              log.info("submitting rcd  {}", allStructuresInCompound);
               submitTasks(owner, allStructuresInCompound, targetPlan, actions, ActionTitleEnum.RCD);
 
+              log.info("submitting rcd member {}", allIndividualsInCompound);
               submitTasks(owner, allIndividualsInCompound.stream()
                   .map(individualObj -> UUID.fromString(individualObj.getId())).collect(
                       Collectors.toList()), targetPlan, actions, ActionTitleEnum.RCD_MEMBER);

diff --git a/src/main/java/com/revealprecision/revealserver/service/TaskService.java b/src/main/java/com/revealprecision/revealserver/service/TaskService.java
@@ -497,6 +497,7 @@ private void submitTaskCandidatesToKafka(Action action, Plan plan, String ownerI
                   taskProcessEvent);
               break;
             case GENERATE:
+              log.debug("submitting tasks {}",taskProcessEvent);
               publisherService.send(
                   kafkaProperties.getTopicMap().get(KafkaConstants.TASK_CANDIDATE_GENERATE),
                   taskProcessEvent);