TEMPO message handler patch (#1192)

Signed-off-by: Angelica Ochoa <[email protected]>
mskcc · Jun 18, 2024 · 9af4591 · 9af4591
1 parent 55df0c0
commit 9af4591
Showing 1 changed file with 5 additions and 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
@@ -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<String, String> 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<String, String> 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<String, String> 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,