Spring 集成和 Spring Cloud Stream

Question

我正在编写一个应用程序

• 轮询目录（Sprint 集成 DSL 流程）

• 一旦文件可用，它将放入rabbitmq队列

• 微服务监听RabbitMQ流并处理文件（这个是用Spring Cloud stream写的）

现在，我无法弄清楚将消息发送到RabbitMQSpring Integration 流服务的最佳方式是什么。如何在 Spring-Integration 中使用 spring-cloud 流将消息发布到 RabbitMQ