有关Spring Integration项目的问题,请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。
UnknownHostException:使用 Spring Integration SMB 为 null
我尝试使用 Spring Integration SMB 在 SMB 共享上写入一些文件。我有以下配置: @配置 公共类 SambaConfiguration { @Value("${samba.host}")
我有一个场景,在应用程序运行时通过 IntegrationFlowContext 创建多个集成流(例如,监听 JMS 队列)并且它工作正常(SpringBoot 3.4.0),但是我们注意到......
Spring Integration:聚合器模式 - 下游组件了解组是否完整的一种方式
我们使用 Spring Integration 6.3.3 聚合器模式,带有 JDBCMessageStore 和过期超时。我们还希望在到期时发送部分组,我们将其视为错误条件。我们...
Spring Integration 作为独立 ESB 的嵌入式替代方案
有人有使用 Spring Integration 项目作为嵌入式 ESB 的经验吗? 我对以下用例非常感兴趣: 按计划从目录中读取文件 从 JDBC 获取数据...
使用多个副本时如何使用 Spring Integration SFTP 正确从 SFTP 服务器获取文件?
目前,我不断收到此错误: org.springframework.messaging.MessagingException 在 org.springframework.integration.endpoint.AbstractPollingEndpoint.pollForMessage(AbstractPollingEndp...
注意:我正在使用 Spring Boot 2.2.0.RELEASE,所以它与此无关。 我有一个 MessagingGateway 如下: @网关( 请求频道 = "我的频道", 标题=@
Spring 集成 - TransactionSynchronizationFactory 中的 TraceId 已更改
TraceId 会发生更改。 调试示例可在 https://github.com/syedyusufh/transaction-sync-traceid 获取 2025-01-05T21:33:21.726...
我创建了新的自定义注释@MyCustomAnnotation: @Target({ElementType.METHOD, ElementType.TYPE, ElementType.FIELD}) @Retention(运行时) 公共@interface MyCustomAnnotation { } 我申请了
尝试了解我们如何将六边形架构与 EIP 结合使用。 在下面的 Spring Boot 示例中,UserMessageHandler 是入站适配器的一部分(根据我的说法),并且被调用...
Spring Batch 使用 Kafka 进行远程分区 - master 始终继续 JobListener 中最旧的作业
我正在使用 spring-batch 和 spring-boot 2.5.6。我决定使用远程分区,并以 Kafka 作为中间件。我有一名经理和三名工人。相应地,一个分区已被分配...
Spring Batch 中的远程分区 - 在大量记录的作业完成之前,少量记录的作业无法完成
我正在尝试使用远程分区[主从方法]的Spring Batch。 我有一个主步骤,通过 KAFKA 将记录发送到工作节点。 一切都工作正常,直到并行作业执行......
拥有一个由多个集成流程组成的 Spring Integration 应用程序,并且该应用程序总共部署为 Kubernetes 中的容器。容器根据负载自动缩放......
Spring Integration & MQ 中设计超时处理
我正在开发一个正在重组为一致异步的应用程序。它过去是,现在仍然是基于 Spring Integrations。作为支付网关,我可以参考ISO 20022标准...
Spring 集成 HttpRequestExecutingMessageHandler ContentType 问题
我面临 Spring Integration 的问题。我正在尝试通过 HttpRequestExecutingMessageHandler 执行休息调用。我的休息端点仅接受内容类型“application/json”。 该项目...
与 Spring Integration Flows 一起使用时如何处理关闭 ExecutorService?
我正在使用执行程序服务来确保传入的 jms 消息在将它们写入数据库后得到确认 - (使用 XA 数据源和分布式事务不是我们的选择...
Spring AMQP 集成从 2.2.3.RELEASE 到 5.5.20
我正在从 Spring AMQP inetgration 从 2.2.3.RELEASE 迁移到 5.5.20.and 这是我的 mvn 依赖树矩阵。 [信息] | +- org.springframework.integration:spring-integration-stream:jar:5.5.20:
使用Spring EL或属性占位符动态设置@Gateway和@ServiceActivator的输入/输出通道
注解@MessagingGateway允许使用属性占位符${}设置defaultRequestChannel: @MessagingGateway(defaultRequestChannel = "${gateway.request.channel}") 公开
我正在使用来自 Kafka 的消息,并使用远程文件服务器上的 SFTP 出站适配器将这些消息写入文件。该应用程序将在云环境中运行多实例。 我正在使用领导者
将 spring 从 4.x 迁移到 5.x 和 jdk 17
我的应用程序中有 spring 依赖项和 spring 集成依赖项。 我已将 spring 从 4.1.1.RELEASE 迁移到 5.3.39,并将 spring 集成从 2.2.3.RELEASE 迁移到 5.5.20。 我有