StockService microservice RabbitMQ

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/pom.xml

@@ -41,6 +41,12 @@
 			<artifactId>spring-rabbit-test</artifactId>
 			<scope>test</scope>
 		</dependency>
+
+		<dependency>
+			<groupId>net.adiletkdev</groupId>
+			<artifactId>order-service</artifactId>
+			<version>0.0.1-SNAPSHOT</version>
+		</dependency>
 	</dependencies>
 
 	<build>

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

@@ -0,0 +1,27 @@
+package net.adiletkdev.stockservice.config;
+
+import org.springframework.amqp.core.*;
+import org.springframework.amqp.rabbit.connection.ConnectionFactory;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
+import org.springframework.amqp.support.converter.MessageConverter;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class RabbitMQConfig {
+
+    // message converter
+    @Bean
+    public MessageConverter converter() {
+        return new Jackson2JsonMessageConverter();
+    }
+
+    // configure RabbitTemplate
+    public AmqpTemplate amqpTemplate(ConnectionFactory connectionFactory) {
+        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
+        rabbitTemplate.setMessageConverter(converter());
+
+        return rabbitTemplate;
+    }
+}

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