Commit 1daa4d53 authored by Shanelle Valencia's avatar Shanelle Valencia

Clean up code

parent 4c84357b
Pipeline #1726 failed with stage
in 38 seconds
...@@ -48,11 +48,10 @@ public class Receiver { ...@@ -48,11 +48,10 @@ public class Receiver {
private void updateOrderStatus(String orderObj) { private void updateOrderStatus(String orderStr) {
try { try {
//deserialize kafka message into java object using ObjectMapper
ObjectMapper objectMapper = new ObjectMapper(); ObjectMapper objectMapper = new ObjectMapper();
Order order = objectMapper.readValue(orderObj, Order.class); Order order = objectMapper.readValue(orderStr, Order.class);
log.info("ORDER objectMapper {}", order); log.info("ORDER objectMapper {}", order);
String orderId = order.getId(); String orderId = order.getId();
...@@ -60,12 +59,12 @@ public class Receiver { ...@@ -60,12 +59,12 @@ public class Receiver {
updated.block(); updated.block();
} catch (Exception e) { } catch (Exception e) {
log.error("Caught error", e); log.error("Caught error on UpdateOrderStatus method", e);
e.printStackTrace();
} }
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment