Commit 7766987

committed

add: StockService microservice - RabbitMQ consumer

1 parent 5e39005 commit 7766987Copy full SHA for 7766987

File tree

+23

-1

lines changed

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

+23

-1

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: 0 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,6 @@`
`5`	`5`	`import org.springframework.amqp.rabbit.core.RabbitTemplate;`
`6`	`6`	`import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;`
`7`	`7`	`import org.springframework.amqp.support.converter.MessageConverter;`
`8`		`-import org.springframework.beans.factory.annotation.Value;`
`9`	`8`	`import org.springframework.context.annotation.Bean;`
`10`	`9`	`import org.springframework.context.annotation.Configuration;`
`11`	`10`

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)