Spring Integration错误："没有可用的输出通道或回复通道头"。
我不确定为什么会出现异常。 Caused by: org.springframework.messaging.core.DestinationResolutionException: no output-channel or replyChannel header available 这...
如何使用MockIntegrationContext.substituteMessageHandlerFor模拟WebFluxRequestExecutingMessageHandler
我已经实现了一个IntegrationFlow，我想要完成以下任务： 从目录中轮询文件 将文件内容转换为字符串 通过WebFluxRequestExecutingMessageHandler将字符串发送到REST端点，并使用AdviceChain处理成功和错误响应 实现 @Confi...
如何在我的Spring Cloud Stream项目中将传入的标头映射为字符串而不是字节数组？
我有一个简单的Spring Cloud Stream项目，使用Spring Integration DSL流和Kafka绑定器，一切都运行良好，但来自Kafka的消息头值作为byte[]到达。 这意味着我的SI @Header参数需要是byte[]类型。虽然可以工作，但最好将它们作为字符串（...
有没有一种方法可以为Spring Integration DSL流程生成图表？
我有一个正在运行的应用程序，它定义了一些使用入站/出站网关、拆分器、聚合器、路由器等创建的 Spring Integration 流程...全部使用 Spring Integration DSL 和注释创建，没有 XML 文件。 是否有任何工具可以为此生成 EE 模式图？ 这个问题 表示 ...
TaskExecutor不工作Spring Integration
我已经使用任务执行器设置了文件轮询器。 ExecutorService executorService = Executors.newFixedThreadPool(10); LOG.info("Setting up the poller for directory...
Spring Integration 5.1 - 使用@IntegrationConverter进行集成流转换无法正常工作
我将Spring Boot版本从2.0.5.RELEASE升级到2.1.8.RELEASE（因此Spring Integration从5.0升级到5.1），在集成流程内的自动类型转换不再起作用。 我习惯于定义一组@IntegrationConverter组件，并在集成流程代码中使用操作tran...