Commit ac96f5b

committed

add: OrderService microservice - REST API to send message

1 parent 53c044b commit ac96f5bCopy full SHA for ac96f5b

File tree

+36

-0

lines changed

order-service/src/main/java/net/adiletkdev/orderservice/controller
- OrderController.java

+36

-0

lines changed

Lines changed: 36 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,36 @@`
	`1`	`+package net.adiletkdev.orderservice.controller;`
	`2`	`+`
	`3`	`+import net.adiletkdev.orderservice.dto.Order;`
	`4`	`+import net.adiletkdev.orderservice.dto.OrderEvent;`
	`5`	`+import net.adiletkdev.orderservice.publisher.OrderProducer;`
	`6`	`+import org.springframework.web.bind.annotation.PostMapping;`
	`7`	`+import org.springframework.web.bind.annotation.RequestBody;`
	`8`	`+import org.springframework.web.bind.annotation.RequestMapping;`
	`9`	`+import org.springframework.web.bind.annotation.RestController;`
	`10`	`+`
	`11`	`+import java.util.UUID;`
	`12`	`+`
	`13`	`+@RestController`
	`14`	`+@RequestMapping("api/v1")`
	`15`	`+public class OrderController {`
	`16`	`+`
	`17`	`+ private OrderProducer orderProducer;`
	`18`	`+`
	`19`	`+ public OrderController(OrderProducer orderProducer) {`
	`20`	`+ this.orderProducer = orderProducer;`
	`21`	`+ }`
	`22`	`+`
	`23`	`+ @PostMapping("orders")`
	`24`	`+ public String placeOrder(@RequestBody Order order) {`
	`25`	`+ order.setOrderId(UUID.randomUUID().toString());`
	`26`	`+`
	`27`	`+ OrderEvent event = new OrderEvent();`
	`28`	`+ event.setStatus("PENDING");`
	`29`	`+ event.setMessage("Order is in pending status");`
	`30`	`+ event.setOrder(order);`
	`31`	`+`
	`32`	`+ orderProducer.sendMessage(event);`
	`33`	`+`
	`34`	`+ return "Order sent to the RabbitMQ";`
	`35`	`+ }`
	`36`	`+}`

Comments

(0)