From 9af459181ef42d11c786f81c86c5a5b5aeecb182 Mon Sep 17 00:00:00 2001 From: ao508 <15623749+ao508@users.noreply.github.com> Date: Tue, 18 Jun 2024 16:18:53 -0400 Subject: [PATCH] TEMPO message handler patch (#1192) Signed-off-by: Angelica Ochoa <15623749+ao508@users.noreply.github.com> --- .../service/impl/TempoMessageHandlingServiceImpl.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/service/src/main/java/org/mskcc/smile/service/impl/TempoMessageHandlingServiceImpl.java b/service/src/main/java/org/mskcc/smile/service/impl/TempoMessageHandlingServiceImpl.java index c95ea42d..ec13038c 100644 --- a/service/src/main/java/org/mskcc/smile/service/impl/TempoMessageHandlingServiceImpl.java +++ b/service/src/main/java/org/mskcc/smile/service/impl/TempoMessageHandlingServiceImpl.java @@ -488,7 +488,7 @@ private void setupBamCompleteHandler(Gateway gateway, @Override public void onMessage(Message msg, Object message) { try { - String bamCompleteJson = mapper.readValue( + String bamCompleteJson = mapper.convertValue( new String(msg.getData(), StandardCharsets.UTF_8), String.class); Map bamCompleteMap = mapper.readValue(bamCompleteJson, Map.class); @@ -516,7 +516,7 @@ private void setupQcCompleteHandler(Gateway gateway, @Override public void onMessage(Message msg, Object message) { try { - String qcCompleteJson = mapper.readValue( + String qcCompleteJson = mapper.convertValue( new String(msg.getData(), StandardCharsets.UTF_8), String.class); Map qcCompleteMap = mapper.readValue(qcCompleteJson, Map.class); @@ -545,7 +545,7 @@ private void setupMafCompleteHandler(Gateway gateway, @Override public void onMessage(Message msg, Object message) { try { - String mafCompleteJson = mapper.readValue( + String mafCompleteJson = mapper.convertValue( new String(msg.getData(), StandardCharsets.UTF_8), String.class); Map mafCompleteMap = mapper.readValue(mafCompleteJson, Map.class); @@ -576,7 +576,7 @@ private void setupCohortCompleteHandler(Gateway gateway, @Override public void onMessage(Message msg, Object message) { try { - String cohortCompleteJson = mapper.readValue( + String cohortCompleteJson = mapper.convertValue( new String(msg.getData(), StandardCharsets.UTF_8), String.class); CohortCompleteJson cohortCompleteData = mapper.readValue(cohortCompleteJson, @@ -596,7 +596,7 @@ private void setupSampleBillingHandler(Gateway gateway, @Override public void onMessage(Message msg, Object message) { try { - String billingJson = mapper.readValue( + String billingJson = mapper.convertValue( new String(msg.getData(), StandardCharsets.UTF_8), String.class); SampleBillingJson billing = mapper.readValue(billingJson,