Spring Integrtation и Spring Cloud Stream

Я пишу заявление, которое

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

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

Источник

1 ответ

Решение

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

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

Источник
Другие вопросы по тегам