Есть ли в ActiveMQ реактивная клиентская библиотека или способ получать сообщения с помощью Spring WebClient?

Question

Я работаю на SMTP-клиенте NIO с Spring Webflux и Reactor Netty. У меня есть требование для интеграции обмена сообщениями в приложение, и мне было интересно, если есть неблокирующий способ взаимодействия с ActiveMQ, единственная документация, которую я нашел, где упоминается NIO в ActiveMQ, говорит только о том, как сервер ActiveMQ использует модель NIO, но ничего о использовании сервиса с неблокирующим клиентом.

Answer 1

Конечно, ActiveMQ, как и любой другой поставщик JMS, имеет блокирующий API ( MessageConsumer.receive () ), а также метод для установки MessageListener , который вызывается автоматически один раз сообщение приходит. Поскольку вы используете Spring, взгляните на этот пример.

Кроме того, вы можете включить NIO на стороне сервера с помощью 'nio' вместо префикса tcp: nio: // имя хоста: порт? Ключ = значение, см. Также https://activemq.apache.org/nio-transport-reference,, но похоже, что NIO реализован только серверная часть соединения клиент-сервер.