spring-integration-dsl 相关问题

Spring Integration Java DSL 流程中的通知器（即发即弃）模式

我是第一次使用 Spring Integration，所以我学得很快。 我有一个工作场景，其中我必须激活多个子流程，但我不能中断或使主要流程...

Spring Integration 重试建议配置

我想配置重试建议。 这行得通吗？ IntegrationFlows.from("inputChannel") .transform(theTranformer , "theTransfomerMethod" , e -> e.handleMessageAdvice(new

在FTP出站网关中，如何在“mv”命令中获取原始文件名？

首先，我列出了一个工作正常的目录中的文件。列出后，我想将文件移动到另一个也可以工作的目录。然而，保留原汁原味是行不通的...

如何使用 spring 集成来池化多个目录而不是创建单独的文件入站适配器？有没有动态的方法来创建这个

如何创建10个以上目录的spring集成？就我而言，目前我们有 2 个位置可供池化，这很容易，我们可以为每个目录创建 2 个不同的文件入站适配器...

Tcp 入站网关不调用串行器，但解串器正在被调用

我们需要监听端口并接收消息，然后我们需要将其写回到同一个输出流中。我们已经编写了运行良好的自定义解串器。但自定义序列化器我...

使用 Spring Batch 集成进行文件监控和处理

我目前正在学习 spring-batch-integration，为此我想创建一个应用程序来监视指定目录中的 txt 文件，然后如果该文件存在则启动批处理作业...

spring集成中poller的查询

我对 Spring 集成以及下面所述的几乎所有内容都是新手。 我有一个 inboundChannelAdapter 来从 pubsub 中的订阅中提取消息。 事实上，它正在从 p 中提取消息...

Spring 集成：Jpa 出站适配器的错误处理

我有一个 Spring Integration 流程，它使用 Jpa.inboundAdapter() 作为源，在转换中操作读取的实体，最后使用 Jpa.outboundAdapter 再次存储它们。 然而，在人...

Spring 集成错误：上传文件时无法写入“foo/002.txt.writing”

我正在试验 SI 示例中的以下示例设置，以了解其内部工作原理，目标是使其适应上层环境中的类似任务集。 DailyCashReport应用...

Spring Integration 文件分割示例不会对进入入站适配器通道的内容做出反应

我正在测试 SI 示例中的以下示例设置，以了解并使其适应类似的任务集。我不需要邮件功能，但其余部分似乎适应性足够......

多个 ThreadStatePropagationChannelInterceptors 不可能

我有一个 Spring Integration 设置，其中配置了一个 SecurityContextPropagationChannelInterceptor，它传播 spring 安全上下文异步通道边界。这效果很好。 我也

imap 邮件接收器

我正在使用 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：通道获取错误的有效载荷

我有这段代码，但它不能正常工作。聚合器获取错误的负载类型 - 实体而不是列表>。谁能解释一下？提前致谢！ 流水线：...

Spring Integration - split() 和 aggregate() 统计

有没有办法通过启用额外的日志记录级别来了解 split() 和 aggregate() 统计信息？我们有 10k 条消息被拆分并处理了 2 个多小时，任何正在发生的统计数据都会......