spring-integration 相关问题

有关Spring Integration项目的问题,请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。

Spring 集成 - 无法在 BeanFactory 中查找名称为“55774d05-e054-4b71-bc7e-ecc53d029e75:20”的 MessageChannel

我有一个带有 spring 集成的 Spring boot 项目。据我了解,它使用分散-聚集模式: @豆 公共 IntegrationFlow getClientsFlow() { 返回 IntegrationFlows.from(

回答 2 投票 0

Spring集成sftp新版本升级问题

错误日志 [sshd-SshClient[thread-4] 警告 o.a.s.c.k.AcceptAllServerKeyVerifier - 服务器上的服务器提供未经验证的 RSA 密钥:SHA256:密钥 [sshd-SshClient[thread-3] 警告 o.a.s.c.s.ClientSessionIm...

回答 1 投票 0

Spring 集成旋转服务器与 SFTP 出站网关的建议

我想问是否可以在 SFTP 出站网关上使用轮换服务器建议,我正在使用 SFTP 入站适配器轮询文件,并且在轮询方法中我使用轮换服务器建议。有效

回答 1 投票 0

Springboot 3.1 和 Spring Integration 6 - IntegrationComponentScan 未扫描 MessagingGateway

将 springboot 从 2.7 升级到 3.1,并且依赖的 spring jar 升级到版本 6。升级后,spring 集成流程无法处理请求。 抛出错误 - 组织。

回答 1 投票 0

JmsOutboundGateway 重试连接 mq -> GatewayReplyListenerContainer refreshConnectionUntilSuccessful (maxAttempts=unlimited)

我对 JmsOutboundGateway 连接超时有疑问(org.springframework.integration.jms.JmsOutboundGateway$GatewayReplyListenerContainer refreshConnectionUntilSuccessful) - 在我的 c...

回答 1 投票 0

如果降序服务激活器出现故障,RequestHandlerCircuitBreakerAdvice 将不起作用

我对 RequestHandlerCircuitBreakerAdvice 有疑问。 在下面的代码中,如果 JmsOutboundGat 出现故障时,将 RequestHandlerCircuitBreakerAdvice 添加为 passThru 和 passThruSecond 中的建议...

回答 1 投票 0

Spring Integration 和 Spring Batch 事务管理器冲突

我正在使用 Spring 集成流程从文件服务器读取文件。我的应用程序将在多个实例上运行。我想确保每个实例仅处理任何文件一次。这就是我

回答 1 投票 0

从 Spring Integration 向 JMS 主题发送第一条消息需要太长时间

我正在使用 Spring Integration 向 Red Hat AMQ 7.8.2 上的 JMS 主题生成消息。应用程序启动/重新启动时发送第一条消息需要 3 到 4 秒,并且确实需要 40 到 50 秒......

回答 1 投票 0

Spring Integration 6.x http 出站网关 http uri 变量表达式不评估应用程序属性

我们在 Spring 集成应用程序中使用基于 xml 的配置。代码正在从 Spring Integration v5.x 升级到 v6.x。有了这个,我们在使用 http 出站网关时看到 -> htt...

回答 1 投票 0

Spring 将 Java DSL 与 Kafka 集成

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

回答 1 投票 0

验证器 Spring 集成

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

回答 1 投票 0

Amq 发送第一条消息到主题的时间太长

我正在使用 spring-integration 生成发送到 AMQ 主题的消息。应用程序启动/重新启动时发送第一条消息需要 3 到 4 秒,消息确实需要 40 到 50 毫秒

回答 1 投票 0

Direct / Executor Channel - 在故障转移策略设置为 true 的情况下绕过一些自定义异常(不要使用其他订阅者)

当抛出自定义异常时,是否有可能绕过直接通道中的故障转移策略? 如果我添加自定义错误通道 - 错误消息将在所有订阅者之后到达错误通道...

回答 1 投票 0

附加到服务激活器的 Spring Retry Recovery 不是处理链的一部分

我正在使用服务激活器的 Spring 集成链来处理来自队列的传入消息。持久化传入消息的服务激活器 messagePersister 之一。如果这是...

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 2 投票 0

执行器通道和直接通道之间的差异 - 直接通道在失败时将消息加倍,但执行器通道在相同情况下不会加倍

我正在尝试使用 Spring Integration 框架查找 java 应用程序中 Executor Channel 和 Direct Channel 之间行为不同的原因。 我想检查故障转移流程并确保消息...

回答 1 投票 0

TcpNioConnection 关闭抛出异常(java.nio.channels.ClosedChannelException)

场景是我们需要配置 maxClient,如果达到它,我们必须关闭连接(如果它大于 maxClient)。为此,我们在列表中添加connectionId,如果列表更大

回答 1 投票 0

迁移到 Spring Boot 3 - 如何处理来自服务器的“[email protected]”请求?

我们的团队有一个应用程序,每天使用 Spring Integration SFTP 从远程服务器获取和处理一次文件。现在,我正在从 Spring Boot 2.7 迁移到 Spring Boot 3。 之后

回答 2 投票 0

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

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

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.