Plantilla de lectura de tiempo para JMS en IBM MQ.

Answer

1. 

   davy.ai

   June 4, 2023 at 11:22 pm

   Como experto en TI especializado en Java, IBM MQ y Spring-JMS, sugiero la siguiente solución:

   Puedes usar ScheduledExecutorService para implementar una lectura programada de un IBM MQ. Primero, configura el factor de contenedor del escuchante para que use un SimpleMessageListenerContainer con una concurrencia de 1, de manera que solo se lea un mensaje por vez. Luego, en el método readMessages, si el mensaje no ha sido consumido, envíalo a una cola nueva usando JmsTemplate, con un retraso de entrega de 5 minutos. Finalmente, programa una tarea usando ScheduledExecutorService para leer mensajes de la nueva cola después de 5 minutos y repetir el proceso en caso de error.

   Aquí hay un ejemplo de implementación:

    @Autowired
    private JmsTemplate jmsTemplate;
   
    @Autowired
    private SimpleMessageListenerContainerFactory listenerContainerFactory;
   
    @Autowired
    private ScheduledExecutorService scheduledExecutorService;
   
    @JmsListener(destination = "${QueueName}", containerFactory = "listenerContainerFactory")
    public void readMessages(TextMessage msg) {
        try {
            // procesa el mensaje
        } catch (Exception e) {
            // envía el mensaje a una nueva cola con un retraso de entrega de 5 minutos
            jmsTemplate.send("NewQueueName", session -> {
                TextMessage message = session.createTextMessage(msg.getText());
                message.setLongProperty(WMQConstants.JMS_IBM_MQMD_DELIVERY_DELAY, 300000);
                return message;
            });
   
            // programa una tarea para leer mensajes de la nueva cola después de 5 minutos
            scheduledExecutorService.schedule(() -> {
                jmsTemplate.setReceiveTimeout(5000);
                TextMessage newMsg = (TextMessage) jmsTemplate.receive("NewQueueName");
                if (newMsg != null) {
                    readMessages(newMsg);
                }
            }, 5, TimeUnit.MINUTES);
        }
    }
   

   ¡Espero que esto ayude! Avísame si tienes alguna otra pregunta.

Comments are closed.