Hacer que Spring RabbitMQ falle en caso de falta de intercambio.

Answer

1. 

   davy.ai

   June 17, 2023 at 5:20 am

   Actualmente, no hay una propiedad directa en Spring Boot o Spring AMQP que permita al aplicativo fallar al intentar enlazar a un intercambiador que no existe. Sin embargo, puede lograr este comportamiento escribiendo código personalizado para lanzar un RuntimeException cada vez que se encuentre un error de canal con el código 404.

   Aquí hay un ejemplo de cómo lograrlo:

   1. Implemente un RabbitMQConnectionListener personalizado que escuche los errores del canal.

   @Component
   public class CustomRabbitMQConnectionListener implements RabbitListenerEndpointRegistry, RabbitMQConnectionListener {
   
       @Override
       public void onCreate(Connection connection) {
           connection.addShutdownListener(cause -> {
               if (cause != null && cause.isHardError() && cause.getReason().equals("NOT_FOUND - no exchange")) {
                   throw new RuntimeException("Failed to bind to non-existent exchange");
               }
           });
       }
   
       // Implemente otros métodos de RabbitListenerEndpointRegistry
   }
   

   1. Agregue el oyente al contenedor Spring.

   @Configuration
   public class RabbitMQConfig {
   
       @Autowired
       private RabbitListenerEndpointRegistry rabbitListenerEndpointRegistry;
   
       @Bean
       public CustomRabbitMQConnectionListener customRabbitMQConnectionListener() {
           CustomRabbitMQConnectionListener listener = new CustomRabbitMQConnectionListener();
           rabbitListenerEndpointRegistry.addListener(listener);
           return listener;
       }
   }
   

   Al implementar un RabbitMQConnectionListener personalizado, puede escuchar los errores del canal y lanzar un RuntimeException cada vez que se encuentre un error de canal con el código 404, lo que indica que no se ha encontrado el intercambiador. El oyente se puede registrar como un bean de Spring y agregar al RabbitListenerEndpointRegistry para que forme parte del contenedor Spring.

   Con esta implementación, la aplicación fallará si intenta enlazar a un intercambiador que no existe.

Comments are closed.