Commit 71809c5

authored

Merge pull request #3 from adiletkdev/develop

OrderService microservice

2 parents d1ec732 + 6299be3 commit 71809c5Copy full SHA for 71809c5

File tree

+32

-1

lines changed

+32

-1

lines changed

Lines changed: 21 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -15,18 +15,30 @@ public class RabbitMQConfig {`
`15`	`15`	`@Value("${rabbitmq.queue.order.name}")`
`16`	`16`	`private String orderQueue;`
`17`	`17`
	`18`	`+ @Value("${rabbitmq.queue.email.name}")`
	`19`	`+ private String emailQueue;`
	`20`	`+`
`18`	`21`	`@Value("${rabbitmq.exchange.name}")`
`19`	`22`	`private String exchange;`
`20`	`23`
`21`	`24`	`@Value("${rabbitmq.binding.routing.key}")`
`22`	`25`	`private String orderRoutingKey;`
`23`	`26`
	`27`	`+ @Value("${rabbitmq.binding.email.routing.key}")`
	`28`	`+ private String emailRoutingKey;`
	`29`	`+`
`24`	`30`	`// spring bean for queue - order queue`
`25`	`31`	`@Bean`
`26`	`32`	`public Queue orderQueue() {`
`27`	`33`	`return new Queue(orderQueue);`
`28`	`34`	`}`
`29`	`35`
	`36`	`+ // spring bean for queue - email queue`
	`37`	`+ @Bean`
	`38`	`+ public Queue emailQueue() {`
	`39`	`+ return new Queue(emailQueue);`
	`40`	`+ }`
	`41`	`+`
`30`	`42`	`// spring bean for exchange`
`31`	`43`	`@Bean`
`32`	`44`	`public TopicExchange exchange() {`
`@@ -42,6 +54,15 @@ public Binding binding() {`
`42`	`54`	`.with(orderRoutingKey);`
`43`	`55`	`}`
`44`	`56`
	`57`	`+ // spring bean binding between exchange and email queue using email routing key`
	`58`	`+ @Bean`
	`59`	`+ public Binding emailBinding() {`
	`60`	`+ return BindingBuilder`
	`61`	`+ .bind(emailQueue())`
	`62`	`+ .to(exchange())`
	`63`	`+ .with(emailRoutingKey);`
	`64`	`+ }`
	`65`	`+`
`45`	`66`	`// message converter`
`46`	`67`	`@Bean`
`47`	`68`	`public MessageConverter converter() {`

Lines changed: 7 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -18,6 +18,9 @@ public class OrderProducer {`
`18`	`18`	`@Value("${rabbitmq.binding.routing.key}")`
`19`	`19`	`private String orderRoutingKey;`
`20`	`20`
	`21`	`+ @Value("${rabbitmq.binding.email.routing.key}")`
	`22`	`+ private String emailRoutingKey;`
	`23`	`+`
`21`	`24`	`private RabbitTemplate rabbitTemplate;`
`22`	`25`
`23`	`26`	`public OrderProducer(RabbitTemplate rabbitTemplate) {`
`@@ -27,6 +30,10 @@ public OrderProducer(RabbitTemplate rabbitTemplate) {`
`27`	`30`	`public void sendMessage(OrderEvent orderEvent) {`
`28`	`31`	`LOGGER.info(String.format("Order event sent to RabbitMQ -> %s", orderEvent.toString()));`
`29`	`32`
	`33`	`+ // send an order event to order queue`
`30`	`34`	`rabbitTemplate.convertAndSend(exchange, orderRoutingKey, orderEvent);`
	`35`	`+`
	`36`	`+ // send an order event to email queue`
	`37`	`+ rabbitTemplate.convertAndSend(exchange, emailRoutingKey, orderEvent);`
`31`	`38`	`}`
`32`	`39`	`}`

Lines changed: 4 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1,3 +1,6 @@`
`1`	`1`	`rabbitmq.queue.order.name=order_queue`
`2`	`2`	`rabbitmq.exchange.name=order_exchange`
`3`		`-rabbitmq.binding.routing.key=order_routing_key`
	`3`	`+rabbitmq.binding.routing.key=order_routing_key`
	`4`	`+`
	`5`	`+rabbitmq.queue.email.name=email_queue`
	`6`	`+rabbitmq.binding.email.routing.key=email_routing_key`

Comments

(0)