Commit d1ec732

authored

Merge pull request #2 from adiletkdev/develop

StockService microservice RabbitMQ

2 parents 4e1cb5c + 7766987 commit d1ec732Copy full SHA for d1ec732

File tree

+56

-0

lines changed

order-service/src/main/java/net/adiletkdev/orderservice/config
- RabbitMQConfig.java
stock-service
- pom.xml
- src/main
  - java/net/adiletkdev/stockservice
    - config
      - RabbitMQConfig.java
    - consumer
      - OrderConsumer.java
  - resources
    - application.properties

+56

-0

lines changed

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -49,6 +49,7 @@ public MessageConverter converter() {`
`49`	`49`	`}`
`50`	`50`
`51`	`51`	`// configure RabbitTemplate`
	`52`	`+ @Bean`
`52`	`53`	`public AmqpTemplate amqpTemplate(ConnectionFactory connectionFactory) {`
`53`	`54`	`RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);`
`54`	`55`	`rabbitTemplate.setMessageConverter(converter());`

Lines changed: 6 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -41,6 +41,12 @@`
`41`	`41`	`<artifactId>spring-rabbit-test</artifactId>`
`42`	`42`	`<scope>test</scope>`
`43`	`43`	`</dependency>`
	`44`	`+`
	`45`	`+ <dependency>`
	`46`	`+ <groupId>net.adiletkdev</groupId>`
	`47`	`+ <artifactId>order-service</artifactId>`
	`48`	`+ <version>0.0.1-SNAPSHOT</version>`
	`49`	`+ </dependency>`
`44`	`50`	`</dependencies>`
`45`	`51`
`46`	`52`	`<build>`

Lines changed: 27 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,27 @@`
	`1`	`+package net.adiletkdev.stockservice.config;`
	`2`	`+`
	`3`	`+import org.springframework.amqp.core.*;`
	`4`	`+import org.springframework.amqp.rabbit.connection.ConnectionFactory;`
	`5`	`+import org.springframework.amqp.rabbit.core.RabbitTemplate;`
	`6`	`+import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;`
	`7`	`+import org.springframework.amqp.support.converter.MessageConverter;`
	`8`	`+import org.springframework.context.annotation.Bean;`
	`9`	`+import org.springframework.context.annotation.Configuration;`
	`10`	`+`
	`11`	`+@Configuration`
	`12`	`+public class RabbitMQConfig {`
	`13`	`+`
	`14`	`+ // message converter`
	`15`	`+ @Bean`
	`16`	`+ public MessageConverter converter() {`
	`17`	`+ return new Jackson2JsonMessageConverter();`
	`18`	`+ }`
	`19`	`+`
	`20`	`+ // configure RabbitTemplate`
	`21`	`+ public AmqpTemplate amqpTemplate(ConnectionFactory connectionFactory) {`
	`22`	`+ RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);`
	`23`	`+ rabbitTemplate.setMessageConverter(converter());`
	`24`	`+`
	`25`	`+ return rabbitTemplate;`
	`26`	`+ }`
	`27`	`+}`

Lines changed: 20 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,20 @@`
	`1`	`+package net.adiletkdev.stockservice.consumer;`
	`2`	`+`
	`3`	`+import net.adiletkdev.orderservice.dto.OrderEvent;`
	`4`	`+import org.slf4j.Logger;`
	`5`	`+import org.slf4j.LoggerFactory;`
	`6`	`+import org.springframework.amqp.rabbit.annotation.RabbitListener;`
	`7`	`+import org.springframework.stereotype.Service;`
	`8`	`+`
	`9`	`+@Service`
	`10`	`+public class OrderConsumer {`
	`11`	`+`
	`12`	`+ private Logger LOGGER = LoggerFactory.getLogger(OrderConsumer.class);`
	`13`	`+`
	`14`	`+ @RabbitListener(queues = {"${rabbitmq.queue.order.name}"})`
	`15`	`+ public void consume(OrderEvent event) {`
	`16`	`+ LOGGER.info(String.format("Order event received -> %s", event.toString()));`
	`17`	`+`
	`18`	`+ // save order event data in database`
	`19`	`+ }`
	`20`	`+}`

Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1 +1,3 @@`
`1`	`1`	`server.port=8081`
	`2`	`+`
	`3`	`+rabbitmq.queue.order.name=order_queue`

Comments

(0)