我创建了一个流，它按状态轮询数据库中的行，验证它们，然后在聚合之后进行收集。处理完整个流后，每一行都设置为适当的状态。但当 ...
升级到Spring Integration 5后，使用消息不再有效
我正在尝试使用Spring Integration 4.3和Spring Boot 1.6将项目升级到Spring Integration 5.1和Spring Boot 2.1。以前我有以下配置：IntegrationFlows.from（...
Spring-Integration：使用公共root的多线程创建sftp目录失败
我有多个线程通过Sftp.outboundAdapter上传sftp文件。每个线程都需要创建一个具有公共根目录的目录路径。我得到一个异常，告诉我共同的根...
spring integration dsl :: stored procedure传递输入参数
我试图将现有的存储过程出站网关xml转换为dsl。
我正在尝试使用Spring Boot，Spring Batch和Spring Integrations配置RemoteChunking任务。我已经配置了一个activeMQ服务器，我开始按照官方配置Spring Batch ...
如何使用Spring Integration处理来自AWS SQS FiFo队列的10多个并发消息
我希望能够使用Spring Integration Workflow一次处理10个以上的SQS消息。从这个问题，建议是使用ExecutorChannel。我更新了我的代码，但仍然......
Spring集成org.springframework.integration.MessageTimeoutException处理
我有以下spring集成流：@Bean public IntegrationFlow innerInFlow（@Value（“$ {jm s.concurrency：10}”）String concurrency）{return IntegrationFlows ...
如何使用MockIntegrationContext.substituteMessageHandlerFor模拟WebFluxRequestExecutingMessageHandler
我已经实现了一个IntegrationFlow，我想要执行以下任务：从目录轮询文件将文件内容转换为字符串通过...发送字符串
我是spring集成的新手，我想为我的应用程序编写单元测试用例。我正在开发一个应用程序，其中集成接口将由其他系统调用我们转换的XML输入...
我在这个版本中使用了spring integration和java-dsl依赖项。 spring-integration-jdbc- 5.0.0M6 spring-integration-ws- 5.0.0M6 spring-integration-http- 5.0.0M6 spring-integration-jmx- 5.0 ....
Spring Integration基于文件名的Flow路径
我需要解压缩并存档和处理其内容。在zip文件中，可能有两种类型的文件个人或公司。这可以通过文件名来区分。处理完......
Spring Integration错误“没有输出通道或replyChannel标头可用”
我不知道为什么我得到异常引起的：org.springframework.messaging.core.DestinationResolutionException：没有输出通道或replyChannel标头可用它只是一个简单的...
Spring Integration - Java DSL中的AMQP推断类型？
我一直致力于使用AMQP在两个微服务之间建立异步消息传递的“铺平道路”。我们希望为每个服务推广使用单独的域对象，这意味着......
如何为IntegrationFlow的不同部分指定不同的errorChannel
我目前正在开发一个Spring Integration DSL项目，我的流程需要根据流失的部分不同地处理错误。我目前的做法是创造......