在为依赖 Kafka 作为消息源的 Spring 集成应用程序编写集成测试时，我经常遇到在两个测试用例之间创建干净的测试状态的问题，因为......
Spring Integration Java DSL 流程中的通知器（即发即弃）模式
我是第一次使用 Spring Integration，所以我学得很快。 我有一个工作场景，其中我必须激活多个子流程，但我不能中断或使主要流程...
我想配置重试建议。 这行得通吗？ IntegrationFlows.from("inputChannel") .transform(theTranformer , "theTransfomerMethod" , e -> e.handleMessageAdvice(new
首先，我列出了一个工作正常的目录中的文件。列出后，我想将文件移动到另一个也可以工作的目录。然而，保留原汁原味是行不通的...
如何使用 spring 集成来池化多个目录而不是创建单独的文件入站适配器？有没有动态的方法来创建这个
如何创建10个以上目录的spring集成？就我而言，目前我们有 2 个位置可供池化，这很容易，我们可以为每个目录创建 2 个不同的文件入站适配器...
我们需要监听端口并接收消息，然后我们需要将其写回到同一个输出流中。我们已经编写了运行良好的自定义解串器。但自定义序列化器我...
我目前正在学习 spring-batch-integration，为此我想创建一个应用程序来监视指定目录中的 txt 文件，然后如果该文件存在则启动批处理作业...
我对 Spring 集成以及下面所述的几乎所有内容都是新手。 我有一个 inboundChannelAdapter 来从 pubsub 中的订阅中提取消息。 事实上，它正在从 p 中提取消息...
我有一个 Spring Integration 流程，它使用 Jpa.inboundAdapter() 作为源，在转换中操作读取的实体，最后使用 Jpa.outboundAdapter 再次存储它们。 然而，在人...
Spring 集成错误：上传文件时无法写入“foo/002.txt.writing”
我正在试验 SI 示例中的以下示例设置，以了解其内部工作原理，目标是使其适应上层环境中的类似任务集。 DailyCashReport应用...
Spring Integration 文件分割示例不会对进入入站适配器通道的内容做出反应
我正在测试 SI 示例中的以下示例设置，以了解并使其适应类似的任务集。我不需要邮件功能，但其余部分似乎适应性足够......
多个 ThreadStatePropagationChannelInterceptors 不可能
我有一个 Spring Integration 设置，其中配置了一个 SecurityContextPropagationChannelInterceptor，它传播 spring 安全上下文异步通道边界。这效果很好。 我也
我正在使用 Spring Boot 2.2.4-RELEASE 和 Spring Integration 5.2.3，并且我正在使用 IntegrationFlow 和 DSL，因为我需要配置多个 IMAP 服务器。 所以我写了这段代码： 字符串流 ID =
Spring Integration Channel() 将消息分发给意外的订阅者
目前我面临 Spring IntegrationFlows 和 channel() 方法的一些问题。 我不确定我错过了什么，或者框架中是否存在错误。 这是流程： @
Spring Integration DSL 流程 - 一次处理一条消息，等待流程完成后再处理下一条消息
我有一个通用任务服务，用于接收要执行的任务。它将任务放到发布-订阅通道上，以便处理特定类型任务的特定实现......
Spring MVC 测试 - 需要多部分 POST json 原始文件名
我使用 spring-boot 2.0.3.RELEASE 和 junit5。我刚刚尝试使用mockMvc 测试多部分请求。 MockMultipartFile file = new MockMultipartFile("file", "contract.pdf", MediaType.
Spring Integration DSL IntegrationFlow filter() 不返回任何内容并无限等待返回
导入org.springframework.boot.SpringApplication; 导入 org.springframework.boot.SpringBootConfiguration; 导入 org.springframework.boot.autoconfigure.EnableAutoConfiguration; 导入组织。
Spring Integration DSL：仅根据消息计数应用聚合器并并行发送到 Http 端点
我对 Spring 注入完全陌生。我正在寻找以下逻辑： 消息被发布到队列通道（这可以更改）。我只想做节流 使用 Spring Injection 聚合...
处理返回 Flux 的 Spring Integration MessageHandler
我的消息处理程序返回一个通量，理想情况下，我希望 spring 集成来处理阻塞/订阅通量，以便我下面的第二个处理程序获得已解析的对象。但是当以下...
Spring Integration：通道获取错误的有效载荷
我有这段代码，但它不能正常工作。聚合器获取错误的负载类型 - 实体而不是列表>。谁能解释一下？提前致谢！ 流水线：...