Как мне получить OpenMQ для пересылки сообщений?

Question

Я слушал очередь OpenMQ асинхронно. Если у меня есть исключение в процессе использования сообщения, есть ли способ заставить OpenMQ снова отправить мне sh это сообщение?

@Bean
public JmsListenerContainerFactory jmsQueueListenerContainerFactory() {
    DefaultJmsListenerContainerFactory jmsListenerContainerFactory = new DefaultJmsListenerContainerFactory();
    jmsListenerContainerFactory.setConnectionFactory(connectionFactory());
    jmsListenerContainerFactory.setPubSubDomain(false);
    jmsListenerContainerFactory.setSessionAcknowledgeMode(Session.AUTO_ACKNOWLEDGE);
    return jmsListenerContainerFactory;
}

MessageConsumer receiver = session.createConsumer(destination);
receiver.setMessageListener(new MessageListener() {
    public void onMessage(Message message) {
        TextMessage text = (TextMessage) message;
        System.out.println("Received message: " + message.getText());

        //The connection timed out when saving the message to the database
        repository.save(text);
    }
});

Answer 1

Причина, по которой он не отменен, заключается в том, что вы подтвердили режим, установленный на AUTO_ACKNOWLEDGE.

jmsListenerContainerFactory.setSessionAcknowledgeMode(Session.AUTO_ACKNOWLEDGE);

Измените его на CLIENT_ACKNOWLEDGE, как показано ниже:

jmsListenerContainerFactory.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);

Использование message.acknowledge() для подтверждения сообщения.

Используйте session.recover() для возврата сообщения.