configure: EmailService microservice - RabbitMQ, create RabbitMQ consumer

Author: adiletkdev

email-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>

email-service/src/main/java/net/adiletkdev/emailservice/config/RabbitMQConfig.java

@@ -0,0 +1,27 @@
+package net.adiletkdev.emailservice.config;
+
+import org.springframework.amqp.core.AmqpTemplate;
+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;
+    }
+}

email-service/src/main/java/net/adiletkdev/emailservice/consumer/OrderConsumer.java

@@ -0,0 +1,20 @@
+package net.adiletkdev.emailservice.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.email.name}"})
+    public void consume(OrderEvent event) {
+        LOGGER.info(String.format("Order event received int email service -> %s", event.toString()));
+
+        // email service needs to email customer
+    }
+}

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

@@ -1 +1,3 @@
-server.port=8082
+server.port=8082
+
+rabbitmq.queue.email.name=email_queue