Spring Integrtation и Spring Cloud Stream
Я пишу приложение, которое
- Опросы в каталоге (поток DSL-интеграции Sprint)
- Как только файл будет доступен, он будет помещен в очередь rabbitmq
- Microservice прослушивает поток RabbitMQ и обрабатывает файл (это написано в потоке Spring Cloud)
Теперь я не могу понять, что является лучшим способом отправить сообщение в 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