spring-integration-dsl 相关问题

从 Spring Integration 5.5 迁移到 6.3

鉴于我们不再有 IntegrationComponentSpec.get() ，正确的解决方案是使用 ChannelSpec 而不是 Channel。但我该如何将其应用到 Kotlin DSL 上呢？ 在我能做之前： ...

@IntegrationFlow DSL 中的角色

使用消息驱动通道适配器时，是否可以通过 IntegrationFlow dsl 指定用于领导选举的端点角色？ 我可以使用...创建 JMS 消息驱动端点...

Spring Integration JMS MessageDrivenChannelAdapter 连接状态

在 Spring 5.3.29 中，如何在未收到消息的情况下检测 MessageDriveChannelAdapter 已连接到 JMS。 目前，我有； IntegrationFlows.from( 杰姆斯 .messageDrivenChannelA...

使用 Java DSL 的消息传递网关的回复通道

我有一个 REST API，它接收来自客户端应用程序的 POST 请求。 @Autowired 私人 EdiTranslationEvents.TransformToStringtransformToString; @PostMapping("/testPost") @

Spring 将 Java DSL 与 Kafka 集成

我正在用kafka spring集成Java DSL做一个poc 我正在从数据库（DB）读取一行并将该行作为消息发送到 Kafka 主题。请找到下面的代码。 代码正在编译，我可以

验证器 Spring 集成

我正在尝试验证 Spring 集成中传入的 xml 数据。我已经使用了验证器并实现了它的方法。但是当我运行应用程序时，我发现该类不支持...

如何在Spring集成文件轮询中多次处理相同的文件，这意味着我想处理该文件，即使它已经处理过

我有一个 Spring 集成文件轮询实现，它正在轮询特定目录，在此过程中将选择文件并将文件相关的元数据传递到下游系统。 S...

Spring 集成流程：寻找避免由于递归流程而导致 java.lang.StackOverflowError 的策略

使用 Spring-Integration 版本 5.5.18，我有一个流程，该流程适用于小型输入集，但由于通过 c... 递归调用，因此对于较大的输入集会遇到 java.lang.StackOverflowError 。

错误消息处理程序是一种单向方式，无法配置输出通道

我有以下配置，并且我在Spring集成Java DSL服务执行器（.handle）中使用了以下样式，应该使用bean @豆 公共 IntegrationFlow 流程（PollerMetada

在 JUnit 集成测试中启动 Spring Integration 轮询器的简洁方法

我有一个 Spring Integration 流程，它利用 MessageSource 定期填充来自数据库查询的消息（不，我不打算使用 Spring Integration JPA/JDBC） @豆 公开

IntegrationFlow 可分割集合并为每个消息创建一个事务

我之前创建了一个集成流程，该流程使用带有 updateExpression 的 MongoDb inboundChannelAdapter 并将其设置为事务性： 集成流程 .来自(MongoDb.

Kotlin 中基于消息头的 Spring Integration DSL 路由

我的消息包含字符串，我想根据标头路由消息，如下所示： .route，字符串> { 当 (it.headers["routing_header&...

如何在解析SFTP服务器上的所有文件时停止IntegrationFlow，并在第二天使用计划功能重新运行它

我有一个 StandardIntegrationFlow，它从 SFTP 服务器上的一堆文件夹中读取一些文件，进行过滤，然后处理通过过滤器的文件。我的文件结构是这样的：/...

声明 MessageChannel beans 的首选方式

我在网上看到的大多数资源都是通过以下方式声明MessageChannels： @豆 消息通道 myChannel() { 返回新的 MessageChannels.direct().get(); } 看来 .get() 方法...

MongoDB 入站适配器更新表达式和事务同步 DSL 示例

与 5 年前的这个问题类似，我试图定义一个 mongodb 源，在轮询时将记录标记为“正在处理”。当流程完成后，我想将记录标记为“完成”。很多都有

Spring 集成 JMS 轮询器以在轮询之间保留会话

我在 IBM MQ 系列队列上有一个 Spring Integration JMS 轮询器。当使用 IBM MQ Explorer（IBM 的基于 Eclipse 的队列浏览器应用程序）并查看队列的状态时，我看到了我的应用程序...

Dispatcher 在使用 spring-integation-mail 时没有订阅者

我们有一个多租户应用程序，它允许用户按需创建 IMAP 邮件获取器（也称为邮件接收器）并单独处理它们。为此，我们决定使用：spring-integration-mail (v ...

如果使用 ImapMailReceiver 将 autoCloseFolder 设置为 false，则手动关闭文件夹

阅读 spring-integration-mail 我尝试加载电子邮件的内容，包括附件。结果，我显然设置了autoCloseFolder=false。现在，文档提到 ClosableResource 应该是你...

如何为每次测试运行使用独特的 Kafka 主题

在为依赖 Kafka 作为消息源的 Spring 集成应用程序编写集成测试时，我经常遇到在两个测试用例之间创建干净的测试状态的问题，因为......

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

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