EmailService microservice

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