Class RabbitmqConfig

java.lang.Object
com.bank.auth_service.config.RabbitmqConfig

@Configuration public class RabbitmqConfig extends Object
Configuration class for RabbitMQ queues and message conversion.

This class defines the beans for the application's RabbitMQ queues and configures the message converter to use Jackson for JSON serialization and deserialization. The queue names are injected from application properties.

  • authQueue: Queue for authentication-related messages
  • emailQueue: Queue for sending email notifications
  • requestNewCodeQueue: Queue for requesting new verification codes
  • sendPaymentQueue: Queue for sending payment-related messages
Since:
1.0.0
Version:
1.0.0, 06/23/2025
Author:
Fernando Cruz Cavina
  • Field Details

    • authQueue

      @Value("${broker.queue.create.auth}") public String authQueue
    • emailQueue

      @Value("${broker.queue.email.sender}") public String emailQueue
    • requestNewCodeQueue

      @Value("${broker.queue.requestNewCode}") public String requestNewCodeQueue
    • sendPaymentQueue

      @Value("${broker.queue.sendPayment}") public String sendPaymentQueue
  • Constructor Details

    • RabbitmqConfig

      public RabbitmqConfig()
  • Method Details

    • authQueue

      @Bean public org.springframework.amqp.core.Queue authQueue()
      Defines the authentication queue bean.
      Returns:
      a durable Queue for authentication messages
    • emailQueue

      @Bean public org.springframework.amqp.core.Queue emailQueue()
      Defines the email queue bean.
      Returns:
      a durable Queue for email messages
    • requestNewCodeQueue

      @Bean public org.springframework.amqp.core.Queue requestNewCodeQueue()
      Defines the request new code queue bean.
      Returns:
      a durable Queue for code request messages
    • sendPaymentQueue

      @Bean public org.springframework.amqp.core.Queue sendPaymentQueue()
      Defines the send payment queue bean.
      Returns:
      a durable Queue for payment messages
    • objectMapper

      @Bean public org.springframework.amqp.support.converter.Jackson2JsonMessageConverter objectMapper()
      Configures the Jackson2JsonMessageConverter bean for message serialization.
      Returns:
      a Jackson2JsonMessageConverter using a custom ObjectMapper