add: StockService microservice - RabbitMQ consumer

Author: adiletkdev

order-service/src/main/java/net/adiletkdev/orderservice/config/RabbitMQConfig.java

@@ -49,6 +49,7 @@ public MessageConverter converter() {
     }
 
     // configure RabbitTemplate
+    @Bean
     public AmqpTemplate amqpTemplate(ConnectionFactory connectionFactory) {
         RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
         rabbitTemplate.setMessageConverter(converter());

stock-service/src/main/java/net/adiletkdev/stockservice/config/RabbitMQConfig.java

@@ -5,7 +5,6 @@
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
 import org.springframework.amqp.support.converter.MessageConverter;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 

stock-service/src/main/java/net/adiletkdev/stockservice/consumer/OrderConsumer.java

@@ -0,0 +1,20 @@
+package net.adiletkdev.stockservice.consumer;
+
+import net.adiletkdev.orderservice.dto.OrderEvent;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Service;
+
+@Service
+public class OrderConsumer {
+
+    private Logger LOGGER = LoggerFactory.getLogger(OrderConsumer.class);
+
+    @RabbitListener(queues = {"${rabbitmq.queue.order.name}"})
+    public void consume(OrderEvent event) {
+        LOGGER.info(String.format("Order event received -> %s", event.toString()));
+
+        // save order event data in database
+    }
+}

stock-service/src/main/resources/application.properties

@@ -1 +1,3 @@
 server.port=8081
+
+rabbitmq.queue.order.name=order_queue