有关Spring Integration项目的问题，请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。
当未提供“通道”引用时，需要通道适配器的“id”属性，因为“id”将用于创建的通道
我正在使用 spring-integration-kafka 1.1.2 版本并面临此错误，我无法定义 id，因为它不允许我这样做，请帮忙。 已添加此代码与 Spring 集成侦听器自定义
我通过 Josh Long YouTube 视频了解了 Spring Integration，我认为它非常适合我们的一个业务案例。 我们想做的事情在纸面上很简单：数据复制。 W...
如何使用 transactionSynchronizationFactory 将文件从入站远程目录移动到另一个远程目录
我的要求是从 FTP 远程目录读取文件，将有效负载值插入数据库，然后将文件从远程目录 /in 移动到同一 FTP 服务器的远程目录 /archive。 我是
如何删除Spring集成的ftp inbound-channel-adapter中的本地文件
我有一个集成案例，从 FTP 获取 xml 有效负载，然后使用 http 出站通道将有效负载发送到 Web 服务，ftp 入站通道适配器有一个名为 local-directory 的强制属性，
Spring Integration：使用 Spring Integration 进行多应用程序集成
我对 Spring Integration 有一些疑问： 我们可以使用 Spring Integration 框架集成两个以上的应用程序吗？ 是点对点集成还是面向中间件的集成...
IntegrationFlow 可分割集合并为每个消息创建一个事务
我之前创建了一个集成流程，该流程使用带有 updateExpression 的 MongoDb inboundChannelAdapter 并将其设置为事务性： 集成流程 .来自(MongoDb.
Mqttv5PahoMessageDrivenChannelAdapter 正在创建带有客户端 ID 前缀的主题
我正在 Spring Boot 应用程序中嵌入 ActiveMQ Artemis，并尝试使用 Spring Integration 中的 Mqttv5PahoMessageDrivenChannelAdapter 连接到 MQTT 端口： @豆 公共客户经理...
spring-integration-sftp v6.1.2抛出DH密钥大小必须是64的倍数，并且只能范围从512到8192。不支持密钥大小4095
我将 spring-integration-sftp 从 5.2.3 RELEASE 升级到 v6.1.2。然后，我得到了异常“由 java.security.InvalidAlgorithmParameterException 引起：DH 密钥大小必须是 64 的倍数，并且...
服务： Message 响应 = mqttGateway.sendToMqtt("topic", jsonData); log.info("接收回复{}",String.valueOf(response.getPayload())); 我有这个
我正在使用 Spring REST、Websocket/STOMP 和 RabbitMQ 开发消息应用程序。我们使用加特林对应用程序的 REST 端点进行负载/压力测试。然而，我们会...
Kotlin 中基于消息头的 Spring Integration DSL 路由
我的消息包含字符串，我想根据标头路由消息，如下所示： .route，字符串> { 当 (it.headers["routing_header&...
我有一个 Spring Boot Web 应用程序，它会在 120 秒超时后正常关闭。 最近，我们向同一应用程序添加了 Spring 集成流程，以便能够处理某些文件...
我有一个 websocket 端点，允许客户端订阅与特定对话相关的消息。消息保存在 MongoDb 集合中，因为有多个实例......
如何在解析SFTP服务器上的所有文件时停止IntegrationFlow，并在第二天使用计划功能重新运行它
我有一个 StandardIntegrationFlow，它从 SFTP 服务器上的一堆文件夹中读取一些文件，进行过滤，然后处理通过过滤器的文件。我的文件结构是这样的：/...
我有一个 Spring Integration 流程，它从数据流中检索数据，对其进行处理，并将结果保存在关系数据库中。流程运行得很好。我想停止/恢复 f...
如果 ResolvableType 已在标头中，则会发生 InvalidDefinitionException
我们在项目中使用了spring集成和spring kafka。 从 Spring-boot 3.1.7 更新到 3.2.1 后，我们在消息序列化期间遇到异常。 给定流程： @豆 综合...
SftpOutboundGateway MGet 在运行时更改远程目录
我想尝试使用 MGet 命令从多个远程目录中提取文件，并将其存储在单独的本地目录中。但文件没有被下载，也没有抛出错误......
Spring Integration 和 JMS：从外部客户端接收消息
在我们的系统中，外部客户端将消息放入 JMS 队列中。 要求我们的 Spring Integration 应用程序从这些队列中获取消息并处理它们。 我最初的尝试...
我在网上看到的大多数资源都是通过以下方式声明MessageChannels： @豆 消息通道 myChannel() { 返回新的 MessageChannels.direct().get(); } 看来 .get() 方法...
我有一个 Spring 集成流程，其中我目前通过使用 Thread.sleep() 引入了手动条件延迟 我知道这是低效的，现在想重构整个......