rabbitmq config

Author: dStrange6

order-service/src/main/java/com/mayank/order_service/ApplicationProperties.java

@@ -0,0 +1,13 @@
+package com.mayank.order_service;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@ConfigurationProperties(prefix = "orders")
+public record ApplicationProperties(
+        String catalogServiceUrl,
+        String orderEventsExchange,
+        String newOrdersQueue,
+        String deliveredOrdersQueue,
+        String cancelledOrdersQueue,
+        String errorOrdersQueue) {}

order-service/src/main/java/com/mayank/order_service/OrderServiceApplication.java

@@ -2,8 +2,12 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.context.properties.ConfigurationPropertiesScan;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
 
 @SpringBootApplication
+@ConfigurationPropertiesScan
+@EnableConfigurationProperties(ApplicationProperties.class)
 public class OrderServiceApplication {
 
 	public static void main(String[] args) {

order-service/src/main/java/com/mayank/order_service/config/RabbitMQConfig.java

@@ -0,0 +1,94 @@
+package com.mayank.order_service.config;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.mayank.order_service.ApplicationProperties;
+import org.springframework.amqp.core.Binding;
+import org.springframework.amqp.core.BindingBuilder;
+import org.springframework.amqp.core.DirectExchange;
+import org.springframework.amqp.core.Queue;
+import org.springframework.amqp.core.QueueBuilder;
+import org.springframework.amqp.rabbit.connection.ConnectionFactory;
+import org.springframework.amqp.rabbit.core.RabbitAdmin;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.amqp.support.converter.JacksonJsonMessageConverter;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+class RabbitMQConfig {
+    private final ApplicationProperties properties;
+
+    RabbitMQConfig(ApplicationProperties properties) {
+        this.properties = properties;
+    }
+
+    @Bean
+    DirectExchange exchange() {
+        return new DirectExchange(properties.orderEventsExchange());
+    }
+
+    @Bean
+    Queue newOrdersQueue() {
+        return QueueBuilder.durable(properties.newOrdersQueue()).build();
+    }
+
+    @Bean
+    Binding newOrdersQueueBinding() {
+        return BindingBuilder.bind(newOrdersQueue()).to(exchange()).with(properties.newOrdersQueue());
+    }
+
+    @Bean
+    Queue deliveredOrdersQueue() {
+        return QueueBuilder.durable(properties.deliveredOrdersQueue()).build();
+    }
+
+    @Bean
+    Binding deliveredOrdersQueueBinding() {
+        return BindingBuilder.bind(deliveredOrdersQueue()).to(exchange()).with(properties.deliveredOrdersQueue());
+    }
+
+    @Bean
+    Queue cancelledOrdersQueue() {
+        return QueueBuilder.durable(properties.cancelledOrdersQueue()).build();
+    }
+
+    @Bean
+    Binding cancelledOrdersQueueBinding() {
+        return BindingBuilder.bind(cancelledOrdersQueue()).to(exchange()).with(properties.cancelledOrdersQueue());
+    }
+
+    @Bean
+    Queue errorOrdersQueue() {
+        return QueueBuilder.durable(properties.errorOrdersQueue()).build();
+    }
+
+    @Bean
+    Binding errorOrdersQueueBinding() {
+        return BindingBuilder.bind(errorOrdersQueue()).to(exchange()).with(properties.errorOrdersQueue());
+    }
+
+    @Bean
+    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory, JacksonJsonMessageConverter converter) {
+        final var rabbitTemplate = new RabbitTemplate(connectionFactory);
+        rabbitTemplate.setMessageConverter(converter);
+        return rabbitTemplate;
+    }
+
+    @Bean
+    public JacksonJsonMessageConverter jacksonConverter() {
+        return new JacksonJsonMessageConverter();
+    }
+    @Bean
+    public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory) {
+        RabbitAdmin admin = new RabbitAdmin(connectionFactory);
+        admin.setAutoStartup(true);
+        return admin;
+    }
+    @Bean
+    ApplicationRunner rabbitInitializer(RabbitAdmin rabbitAdmin) {
+        return args -> rabbitAdmin.initialize();
+    }
+
+
+}

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

@@ -5,6 +5,12 @@ management.endpoints.web.exposure.include=*
 management.info.git.mode=full
 
 ######## Order Service Config ########
+orders.catalog-service-url=http://localhost:8081
+orders.order-events-exchange=orders-exchange
+orders.new-orders-queue=new-orders
+orders.delivered-orders-queue=delivered-orders
+orders.cancelled-orders-queue=cancelled-orders
+orders.error-orders-queue=error-orders
 
 ###### Db Config ######
 spring.datasource.url=${DB_URL:jdbc:postgresql://localhost:25432/postgres}
@@ -16,4 +22,5 @@ spring.jpa.open-in-view=false
 spring.rabbitmq.host=${RABBITMQ_HOST:localhost}
 spring.rabbitmq.port=${RABBITMQ_PORT:5672}
 spring.rabbitmq.username=${RABBITMQ_USERNAME:guest}
-spring.rabbitmq.password=${RABBITMQ_PASSWORD:guest}
+spring.rabbitmq.password=${RABBITMQ_PASSWORD:guest}
+spring.rabbitmq.dynamic=true