Answer

1. 

   davy.ai

   July 20, 2023 at 2:15 am

   Solución para Lograr el Escenario en la Aplicación

   Paso 1

   Para consumir el mensaje del intercambio entrante cuando la aplicación está activa, podemos usar la anotación @RabbitListener en nuestro código. Esta anotación vincula un método a una cola de mensajes de RabbitMQ y maneja automáticamente la consumición de mensajes.

   Ejemplo:

   @RabbitListener(queues = "${com.rabbitmq.queueName}")
   public void consumeMessage(Message message) {
     // Manejar el mensaje consumido
   }
   

   Aquí, "${com.rabbitmq.queueName}" se refiere al nombre de la cola entrante. Este método se invocará automáticamente cuando haya un mensaje en la cola.

   Paso 2

   Si ocurre alguna excepción/error durante la consumición del mensaje, podemos utilizar la funcionalidad Dead Letter Exchange de RabbitMQ para redirigir el mensaje a una Cola Dead Letter. Las Colas Dead Letter se utilizan para almacenar mensajes que no se pueden procesar por algún motivo.

   Ejemplo:

   @RabbitListener(queues = "${com.rabbitmq.queueName}")
   public void consumeMessage(Message message) {
     try {
       // Manejar el mensaje consumido
     } catch (Exception e) {
       rabbitTemplate.send(rabbitMQConfig.getDeadLetterExchange(), rabbitMQConfig.getDeadLetterRoutingKey(), message);
     }
   }
   

   Aquí, rabbitTemplate.send se utiliza para enviar el mensaje al Dead Letter Exchange con la clave de enrutamiento proporcionada.

   Paso 3

   Para redirigir mensajes a la Cola ParkingLot durante un tiempo de inactividad, podemos dejar de consumir mensajes de la cola entrante y utilizar rabbitTemplate de RabbitMQ para enviar el mensaje a la Cola ParkingLot.

   Ejemplo:

   @RabbitListener(queues = "${com.rabbitmq.queueName}")
   public void consumeMessage(Message message) {
     try {
       // Manejar el mensaje consumido
   
       // Verificar si hay tiempo de inactividad en curso
       if(downtime) {
         registry.getListenerContainer("msgId").stop();
         rabbitTemplate.send(rabbitMQConfig.getExchange(), rabbitMQConfig.getParkingLotRoutingKey(), message);
       }
     } catch (Exception e) {
       rabbitTemplate.send(rabbitMQConfig.getDeadLetterExchange(), rabbitMQConfig.getDeadLetterRoutingKey(), message);
     }
   }
   

   Aquí, registry.getListenerContainer("msgId").stop() deja de consumir mensajes de la cola entrante al obtener el contenedor de escucha con el id proporcionado. Luego, se utiliza rabbitTemplate.send para enviar el mensaje a la Cola ParkingLot con la clave de enrutamiento proporcionada.

   Paso 4

   Para consumir el mensaje de la Cola ParkingLot cuando finalice el tiempo de inactividad y luego consumir mensajes normalmente utilizando la Cola Entrante, podemos primero consumir mensajes de la Cola ParkingLot y luego comenzar a consumir mensajes de la Cola Entrante.

   Ejemplo:

   @RabbitListener(queues = "${com.rabbitmq.parkingLotQueueName}", id="parkingLotId")
   public void consumeParkingLot(Message message) {
     // Manejar el mensaje consumido
   
     // Una vez finalizado el tiempo de inactividad, comenzar a consumir mensajes normalmente
     Message parkedMessage = rabbitTemplate.receive(rabbitMQConfig.getParkingLotQueueName());
     if (parkedMessage == null) {
       registry.getListenerContainer("msgId").start();
     } else {
       rabbitTemplate.send(rabbitMQConfig.getExchange(), rabbitMQConfig.getQueueName(), parkedMessage);
     }
   }
   
   @RabbitListener(queues = "${com.rabbitmq.queueName}", id="msgId")
   public void consumeMessage(Message message) {
     // Manejar el mensaje consumido
   }
   

   Aquí, @RabbitListener con "${com.rabbitmq.parkingLotQueueName}" y "parkingLotId" se utiliza para consumir mensajes de la Cola ParkingLot. Una vez finalizado el tiempo de inactividad, primero verificamos si hay mensajes estacionados en la Cola ParkingLot. Si los hay, los enviamos de vuelta a la Cola Entrante usando rabbitTemplate.send. Si no los hay, comenzamos a consumir mensajes de la Cola Entrante obteniendo el contenedor de escucha con el id "msgId" y activándolo.

   Conclusión

   Sí, el escenario proporcionado se puede implementar utilizando los pasos proporcionados anteriormente. La solución proporcionada es una forma correcta de lograr el escenario dado.

Comments are closed.