Spring Integrtation и Spring Cloud Stream - PullRequest
Новая
       7

Spring Integrtation и Spring Cloud Stream

0 голосов
/ 03 октября 2018

Я пишу приложение, которое

  • Опрашивает каталог (поток DSL интеграции Sprint)
  • Как только файл доступен, он помещается в rabbitmq.очередь
  • Микросервис прослушивает поток RabbitMQ и обрабатывает файл (это написано в потоке Spring Cloud)

Теперь я не могу понять, что такоелучший способ отправить сообщение в RabbitMQ из службы потоков Spring Integration.Как использовать Spring-Cloud Stream в Spring-Integration для публикации сообщения в RabbitMQ

1 Ответ

0 голосов
/ 03 октября 2018

Вам просто нужно реализовать привязку Source и использовать RabbitMQ Binder для получения из вашего источника.Таким образом, результат опроса файлов из каталога будет опубликован в Source.OUTPUT (или в вашей пользовательской привязке), а все остальное будет сделано с помощью RabbitMQ Binder: https://docs.spring.io/spring-cloud-stream/docs/Fishtown.M3/reference/htmlsingle/#spring-cloud-stream-overview-producing-consuming-messages

Конечно, вы можетесделать что-то подобное с простой интеграцией Spring, используя AmqpOutboundEndpoint, чтобы опубликовать сообщение для соответствующего обмена на RabbitMQ: https://docs.spring.io/spring-integration/docs/5.0.8.RELEASE/reference/html/amqp.html#amqp-outbound-channel-adapter

...