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

Есть идеи?

10000