Я пишу приложение, которое
Теперь я не могу понять, что является лучшим способом отправить сообщение в RabbitMQ
из службы потока интеграции Spring. Как я могу использовать Spring-облачный поток в Spring-Integration, чтобы опубликовать сообщение в RabbitMQ
Всего 1 ответ
Вам просто нужно реализовать там привязку Source
и использовать RabbitMQ Binder для создания из вашего источника. Таким образом, результат опроса файлов из каталога будет опубликован в Source.OUTPUT
(или вашей пользовательской привязке), и все остальное будет сделано с помощью RabbitMQ Binder: https://docs.spring.io/spring-cloud -stream / документы / Fishtown.M3 / ссылка / htmlsingle / # весна-облако поток-обзор продуцирующих затрат-сообщений
Конечно, вы можете сделать что-то подобное с простой интеграцией Spring, используя AmqpOutboundEndpoint
чтобы опубликовать сообщение для соответствующего обмена на RabbitMQ: https://docs.spring.io/spring-integration/docs/5.0.8.RELEASE/reference /html/amqp.html#amqp-outbound-channel-adapter