Я использую AMQ вместе с платформой Springboot, и мое решение заключается в том, что я создаю несколько сообщений и помещаю их в одну очередь DLQ. Затем есть одно задание cron, которое периодически запускается, ищет все сообщения в очереди и отправляет их снова.
Но я не уверен, что покажем, что мы можем получить ожидающие сообщения, используя Java и Spring.
Код шаблона JMS:
JmsTemplate jmsTemplate = new JmsTemplate();
jmsTemplate.setConnectionFactory(atsConnectionFactory(queueName, true));
jmsTemplate.setSessionAcknowledgeMode(Session.SESSION_TRANSACTED);
jmsTemplate.setDeliveryMode(DeliveryMode.PERSISTENT);
jmsTemplate.setSessionTransacted(true);
return jmsTemplate;
Вот скриншот консоли activemq с сообщениями в очереди. Я хочу прочитать эти ожидающие сообщения, используя код Java.
Может ли кто-нибудь помочь мне в этом.
Спасибо
