Spring JMS и ActiveMQ Artemis: управление таймаутом для синхронных сообщений ⇐ JAVA
Spring JMS и ActiveMQ Artemis: управление таймаутом для синхронных сообщений
У меня есть огромное приложение, использующее JMS для связи. К сожалению, на данный момент все сообщения синхронны, и мы используем метод JmsTemplate#sendAndReceive.
Хорошо, это работает! Но....
Если у нас есть таймаут, производитель закрывает временную очередь (определенную для получения ответа), как и ожидалось. Но когда прослушиватель завершит обработку, он заново создаст временную очередь для отправки ответа. Эта очередь является временной (без потребителя), но адрес также не помечается как временный.
В результате у нас есть несколько адресов и очередей, ожидающих обработки ответа потребителем, и этого никогда не произойдет.
Как предотвратить повторное создание временной очереди, если производитель (исходного сообщения) закрыл ее раньше и больше не ждет?
Изменить: я использую Artemis 2.29.0, но с последней версией 2.31.0 у меня такое же поведение
У меня есть огромное приложение, использующее JMS для связи. К сожалению, на данный момент все сообщения синхронны, и мы используем метод JmsTemplate#sendAndReceive.
Хорошо, это работает! Но....
Если у нас есть таймаут, производитель закрывает временную очередь (определенную для получения ответа), как и ожидалось. Но когда прослушиватель завершит обработку, он заново создаст временную очередь для отправки ответа. Эта очередь является временной (без потребителя), но адрес также не помечается как временный.
В результате у нас есть несколько адресов и очередей, ожидающих обработки ответа потребителем, и этого никогда не произойдет.
Как предотвратить повторное создание временной очереди, если производитель (исходного сообщения) закрыл ее раньше и больше не ждет?
Изменить: я использую Artemis 2.29.0, но с последней версией 2.31.0 у меня такое же поведение
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение
-
-
ActiveMq Artemis JMS Client застрял в argemessagecontrollerimpl.waitcompletion
Anonymous » » в форуме JAVA - 0 Ответы
- 4 Просмотры
-
Последнее сообщение Anonymous
-
-
-
Как получить внутренний идентификатор сообщений о потреблении сообщения ActiveMQ Artemis?
Anonymous » » в форуме C# - 0 Ответы
- 2 Просмотры
-
Последнее сообщение Anonymous
-