有关Spring Integration项目的问题，请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。
我在 Spring Integration - MessagingGateway 方面遇到问题。我创建了网关接口，并将两个 ServiceActivator 附加到它的 requestChannel 上。 一切正常，但我想监控...
使用 Spring Integration 将对象转换为 JSON 到 MQTT 负载
我正在尝试使用 Spring Integration 通过 MQTT 消息发送 JSON 作为有效负载。这是我的出站处理程序： @豆 @ServiceActivator(inputChannel = MQTT_OUTBOUND_CHANNEL) 公开
使用Spring Integration Sftp上传文件时写入文件失败
我尝试使用 emberstack/sftp 或 atmoz/sftp 在 Docker 容器中托管 sftp 服务器以进行测试。 sftp： 图片：emberstack/sftp 卷： - ./data/sftp.json:/app/config...
如何重启SimpleMessageListenerContainer
我尝试使用 Spring Boot 连接到 RabbitMQ。连接应始终重新启动/重试连接。我在发生致命异常后重新连接时遇到问题。应用程序永远不会丢失
在 JUnit 集成测试中启动 Spring Integration 轮询器的简洁方法
我有一个 Spring Integration 流程，它利用 MessageSource 定期填充来自数据库查询的消息（不，我不打算使用 Spring Integration JPA/JDBC） @豆 公开
Spring集成升级问题。无法注册 MBean [bean 'org.springframework.integration.config.RouterFactoryBean#0'
我已将spring（无启动）应用程序升级到java 17和spring 6.1.3，spring集成的版本也从4.1.2.RELEASE升级到6.2.1。我已经成功构建了 jar，但是当我...
我有简单的 Outlook 邮件接收器，带有轮询器和任务执行器。 每 25 秒轮询一次固定延迟 每次轮询的最大消息数 2 最大获取大小 1 邮箱有8封邮件 第一次民意调查需要 2 条消息和 fetc...
我有一个简单的案例，我需要使用 Spring Cloud Stream 3.2.4 版本来实现。 我有一个预定的消息生产者： 公共类 MySourceOfMessagesImpl { 私人随机随机...
当未提供“通道”引用时，需要通道适配器的“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 集成流程，以便能够处理某些文件...