有关Spring Integration项目的问题,请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。
我有一个 REST API,它接收来自客户端应用程序的 POST 请求。 @Autowired 私人 EdiTranslationEvents.TransformToStringtransformToString; @PostMapping("/testPost") @
Spring 集成 - 无法在 BeanFactory 中查找名称为“55774d05-e054-4b71-bc7e-ecc53d029e75:20”的 MessageChannel
我有一个带有 spring 集成的 Spring boot 项目。据我了解,它使用分散-聚集模式: @豆 公共 IntegrationFlow getClientsFlow() { 返回 IntegrationFlows.from(
错误日志 [sshd-SshClient[thread-4] 警告 o.a.s.c.k.AcceptAllServerKeyVerifier - 服务器上的服务器提供未经验证的 RSA 密钥:SHA256:密钥 [sshd-SshClient[thread-3] 警告 o.a.s.c.s.ClientSessionIm...
我想问是否可以在 SFTP 出站网关上使用轮换服务器建议,我正在使用 SFTP 入站适配器轮询文件,并且在轮询方法中我使用轮换服务器建议。有效
Springboot 3.1 和 Spring Integration 6 - IntegrationComponentScan 未扫描 MessagingGateway
将 springboot 从 2.7 升级到 3.1,并且依赖的 spring jar 升级到版本 6。升级后,spring 集成流程无法处理请求。 抛出错误 - 组织。
我对 JmsOutboundGateway 连接超时有疑问(org.springframework.integration.jms.JmsOutboundGateway$GatewayReplyListenerContainer refreshConnectionUntilSuccessful) - 在我的 c...
如果降序服务激活器出现故障,RequestHandlerCircuitBreakerAdvice 将不起作用
我对 RequestHandlerCircuitBreakerAdvice 有疑问。 在下面的代码中,如果 JmsOutboundGat 出现故障时,将 RequestHandlerCircuitBreakerAdvice 添加为 passThru 和 passThruSecond 中的建议...
Spring Integration 和 Spring Batch 事务管理器冲突
我正在使用 Spring 集成流程从文件服务器读取文件。我的应用程序将在多个实例上运行。我想确保每个实例仅处理任何文件一次。这就是我
从 Spring Integration 向 JMS 主题发送第一条消息需要太长时间
我正在使用 Spring Integration 向 Red Hat AMQ 7.8.2 上的 JMS 主题生成消息。应用程序启动/重新启动时发送第一条消息需要 3 到 4 秒,并且确实需要 40 到 50 秒......
Spring Integration 6.x http 出站网关 http uri 变量表达式不评估应用程序属性
我们在 Spring 集成应用程序中使用基于 xml 的配置。代码正在从 Spring Integration v5.x 升级到 v6.x。有了这个,我们在使用 http 出站网关时看到 -> htt...
我正在用kafka spring集成Java DSL做一个poc 我正在从数据库(DB)读取一行并将该行作为消息发送到 Kafka 主题。请找到下面的代码。 代码正在编译,我可以
我正在尝试验证 Spring 集成中传入的 xml 数据。我已经使用了验证器并实现了它的方法。但是当我运行应用程序时,我发现该类不支持...
我正在使用 spring-integration 生成发送到 AMQ 主题的消息。应用程序启动/重新启动时发送第一条消息需要 3 到 4 秒,消息确实需要 40 到 50 毫秒
Direct / Executor Channel - 在故障转移策略设置为 true 的情况下绕过一些自定义异常(不要使用其他订阅者)
当抛出自定义异常时,是否有可能绕过直接通道中的故障转移策略? 如果我添加自定义错误通道 - 错误消息将在所有订阅者之后到达错误通道...
附加到服务激活器的 Spring Retry Recovery 不是处理链的一部分
我正在使用服务激活器的 Spring 集成链来处理来自队列的传入消息。持久化传入消息的服务激活器 messagePersister 之一。如果这是...
如何在Spring集成文件轮询中多次处理相同的文件,这意味着我想处理该文件,即使它已经处理过
我有一个 Spring 集成文件轮询实现,它正在轮询特定目录,在此过程中将选择文件并将文件相关的元数据传递到下游系统。 S...
Spring 集成流程:寻找避免由于递归流程而导致 java.lang.StackOverflowError 的策略
使用 Spring-Integration 版本 5.5.18,我有一个流程,该流程适用于小型输入集,但由于通过 c... 递归调用,因此对于较大的输入集会遇到 java.lang.StackOverflowError 。
执行器通道和直接通道之间的差异 - 直接通道在失败时将消息加倍,但执行器通道在相同情况下不会加倍
我正在尝试使用 Spring Integration 框架查找 java 应用程序中 Executor Channel 和 Direct Channel 之间行为不同的原因。 我想检查故障转移流程并确保消息...
TcpNioConnection 关闭抛出异常(java.nio.channels.ClosedChannelException)
场景是我们需要配置 maxClient,如果达到它,我们必须关闭连接(如果它大于 maxClient)。为此,我们在列表中添加connectionId,如果列表更大
迁移到 Spring Boot 3 - 如何处理来自服务器的“[email protected]”请求?
我们的团队有一个应用程序,每天使用 Spring Integration SFTP 从远程服务器获取和处理一次文件。现在,我正在从 Spring Boot 2.7 迁移到 Spring Boot 3。 之后