integration changes continued

src/main/java/com/afp/ordermanagement/controller/OrderController.java

@@ -37,9 +37,13 @@ public class OrderController {
     @PostMapping("/orders")
     @ResponseStatus(HttpStatus.CREATED)
     public Mono<Order> getOrderFromEcom(@RequestBody Order orderObject) {
-        Mono<Order> orderCreated = orderService.createOrder(orderObject);
+//        Mono<Order> orderCreated = orderService.createOrder(orderObject);
+        return orderService.createOrder(orderObject)
+                .doOnSuccess(order -> {
+                    orderObject.setId(order.getId());
+                    System.out.println("sending order*******************" + orderObject.getId());
                     sender.sendOrderToTopic(orderObject);
-        return orderCreated;
+                });
     }
 
 

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

@@ -23,7 +23,7 @@ public class Sender {
     private KafkaSender<String, Order> kafkaEventProducer;
 
 
-    private static final String ORDER_TOPIC = "orders";
+    private static final String ORDER_TOPIC = "OMS_ORDER_UPDATE";
 
 
     public void sendOrderToTopic(Order orderObject) {

src/main/java/com/afp/ordermanagement/service/OrderService.java

@@ -28,6 +28,7 @@ public class OrderService {
         newOrder.setOrderTrackingCode(defaultOrderTrackingCode);
         newOrder.setOrderCreatedAt(serviceSystemTime);
         newOrder.setOrderUpdatedAt(serviceSystemTime);
+        //newOrder.setId("abc123");
         //System.out.println(newOrder);
         return orderRepository.save(newOrder);
     }

src/main/resources/application.properties

@@ -3,7 +3,7 @@ kafka.producer.bootstrap-servers=localhost:9092
 kafka.producer.acks=all
 kafka.consumer.bootstrap-servers=localhost:9092
 kafka.consumer.group-id=group_id
-kafka.topic.input=orders
+kafka.topic.input=WMOS_ORDER_UPDATE
 
 server.port=8084