[AFP-53] ✨ Added endpoint testing for kafka update [@svalencia]

src/main/java/com/afp/ordermanagement/reactivekafkaservice/Receiver.java

@@ -32,8 +32,6 @@ public class Receiver {
     @Autowired
     private OrderService orderService;
 
-    @Autowired
-    private OrderRepository orderRepository;
 
     @Autowired
     private EmailService emailService;
@@ -43,13 +41,13 @@ public class Receiver {
         kafkaReceiver.receive()
                 .doOnNext(record -> System.out.println(record))
                 .doOnNext(record -> log.info("record.value(): {} ", record.value()))
-//                .doOnNext(record -> {
-//                    if (record.key() != null) {
-//                        updateOrderStatus(record.value());
-//                    } else {
-//                        log.error("{} is :::::: ", record.value());
-//                    }
-//                })
+                .doOnNext(record -> {
+                    if (record.key() != null) {
+                        updateOrderStatus(record.value());
+                    } else {
+                        log.error("{} is :::::: ", record.value());
+                    }
+                })
                 .doOnNext(record -> updateOrderStatus(record.value()))
                 .doOnError(throwable -> System.out.println(throwable.getMessage()))
                 .subscribe();
@@ -60,22 +58,16 @@ public class Receiver {
 
     private void updateOrderStatus(String orderStr) {
         try {
-//            if (orderStr.isEmpty()) {
-//                log.info("ORDERSTR IS EMPTYYYYYY");
-//                return;
-//            } else {
-                ObjectMapper objectMapper = new ObjectMapper();
-                Order order = objectMapper.readValue(orderStr, Order.class);
-                log.info("ORDER objectMapper {}", order);
-                String orderId = order.getId();
-
-                System.out.println("About to try sending an email.");
-                emailService.emailCreator(order);
-
-                Mono<Order> updated = orderService.updateOrderByOrderId(orderId, order);
-                updated.subscribe();
-//            }
+            ObjectMapper objectMapper = new ObjectMapper();
+            Order order = objectMapper.readValue(orderStr, Order.class);
+            log.info("ORDER objectMapper {}", order);
+            String orderId = order.getId();
+
+            System.out.println("About to try sending an email.");
+            emailService.emailCreator(order);
 
+            Mono<Order> updated = orderService.updateOrderByOrderId(orderId, order);
+            updated.subscribe();
         } catch (Exception e) {
             log.error("Caught error on UpdateOrderStatus method", e);
 //            e.printStackTrace();