adding requestId to sample update message

Signed-off-by: Divya Madala <71040191+divyamadala30@users.noreply.github.com>
mskcc · Nov 30, 2022 · e11b766 · e11b766
1 parent 2028204
commit e11b766
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/main/java/org/mskcc/smile/service/impl/LabelGenMessageHandlingServiceImpl.java b/src/main/java/org/mskcc/smile/service/impl/LabelGenMessageHandlingServiceImpl.java
@@ -16,6 +16,8 @@
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.Phaser;
 import java.util.concurrent.TimeUnit;
+import org.apache.commons.lang.StringUtils;
+import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.mskcc.cmo.messaging.Gateway;
@@ -583,6 +585,12 @@ public void onMessage(Message msg, Object message) {
                             String.class);
                     SampleMetadata sampleMetadata =
                             mapper.readValue(sampleMetadataJson, SampleMetadata.class);
+                    if (StringUtils.isEmpty(sampleMetadata.getIgoRequestId())) {
+                        String requestId = ObjectUtils.firstNonNull(
+                                sampleMetadata.getAdditionalProperties().get("requestId"),
+                                sampleMetadata.getAdditionalProperties().get("igoRequestId"));
+                        sampleMetadata.setIgoRequestId(requestId);
+                    }
                     messageHandlingService.cmoSampleLabelUpdateHandler(sampleMetadata);
                 } catch (Exception e) {
                     e.printStackTrace();