有关Spring Integration项目的问题,请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。
我正在尝试调用 PostgreSQL 的函数/存储过程(它返回游标)。我通过 Spring Integration 的stored-proc-outbound-gateway 调用该函数。它给了我以下错误: ...
Spring Integration TCP 客户端无法从外部 TCP 服务器接收消息
我有一个用例,我需要将消息发送到具有 2 个 IP/端口的外部 TCP 服务器以进行循环分发(每对 IP/端口的每个连接,并且它应该保持消息活动状态
spring集成错误:单向'MessageHandler'并且它不合适
我正在编写一个简单的集成流程,将文件通过 sftp 传输到远程服务器,并希望停止远程服务器上的临时文件重命名。 为了实现这一目标,我尝试创建以下内容......
Spring 集成 - TracingContext 在 WebFluxRequestExecutingMessageHandler 中丢失
这个问题是 SO 问题 Spring Integration Restore ReactorContext into Imperative Handling 的扩展 通过 WebFluxRequestExecutingMessageHandler 调用 WebFlux 后抛出的任何异常...
Spring 集成将 ReactorContext 恢复为命令式处理
通过在反应式和命令式处理之间切换的复杂 IntegrationFlow,我们看到了 ObservationContext (traceId) 在 WebFlux.outboundGat 之后立即更改的行为...
Spring 集成 JMS 通道错误 - SpelEvaluationException:EL1078E
我最近将我的 Spring Boot 应用程序以及其他依赖项 jar 从 java 11 升级到了 java 17 - 升级后的 gradle jar 差异 应用程序使用 Spring 集成来消费来自 JMS 队列的消息...
Spring Integration Aggregator 存在轮询困难
我很难理解有关聚合器使用的文档。 我使用轮询器从文件系统获取文件,然后使用自定义类解析 XML 文件。到目前为止...
文件输入适配器不轮询/处理同一文件,尽管从 AcceptOnceFileListFilter 中删除了该文件
我在 xml 中创建了 AcceptOnceFileListFilter bean 并引用下面的 ChainFileListFilter 内部是我的链过滤器的顺序 链表过滤器 正则表达式模式文件列表过滤器
@Bean 公共 ClientManager clientManager() { MqttConnectionOptions 连接选项 = new MqttConnectionOptions(); 连接选项.setServe...
使用 Spring Integration Mqttv5 共享订阅未接收消息
我有一个使用 spring-integration-mqtt (v. 6.0.4)的 spring boot (v. 3.0.5)项目,并且还使用 paho mqttv5 客户端。我想通过 ClientManager 和集成 DSL 设置共享订阅...
如何使用 IntegrationFlowExtension 处理输入数据
我想创建一个自定义 Spring 集成 DSL 以避免我们的产品中出现样板代码。更具体地说,我们正在创建很多流程,从 AMQP0.9 队列接收数据,转换...
使用 Spring Integration 进行 TCP 代理协议反序列化
我正在尝试找出通过 TCP 连接解析代理协议标头的最佳方法。代理标头中的数据用于确定是否应接受或拒绝连接。 那个...
Spring-Integration 应用程序在迁移到 Azure Spring Apps 服务后缺少一些集成指标
我们有 Spring-Integration 微服务,它使用 JMS 来处理 MQ 消息。 消息管理器应用程序(另一个应用程序)对这个应用程序进行其余调用以获取有关成功和失败混乱的统计信息...
Spring 集成 Java DSL TCP 出站和入站连接处理程序
我需要创建一个动态 TCP 出站适配器,充当客户端、连接到服务器并处理服务器的响应。虽然请求已正确发送到服务器,但我无法
我有一个用例,我需要使用 TCP 套接字向外部系统发出请求并等待响应。我知道如果我作为客户端连接,则可以使用 Spring Integration Outbound Gateway....
我正在实现一个 @InboundChannelAdapter 场景,其中我需要在将消息发送到 AWS SQS 队列后将文件移动到远程存档目录。我已经成功实现了类似的场景
使用 serviceActivator 进行 junit 测试集成流程
在我的 spring-boot 项目中,我有以下课程: @配置 @EnableIntegration 公共类 ConsumeFiles { @豆 公共 IntegrationFlow inboundFileFromDirectory(@Value("${pe...
Spring Cloud Streams Kafka Binder - 日志处理程序记录完整的有效负载
我正在将 Spring Cloud Streams 与 Kafka Binder 一起使用。我可以看到有效负载被记录为 failedMessage=GenericMessage[payload=[….etc。通过日志处理程序 就我而言,我的有效负载包含敏感数据
Spring Integration支持SMPP(短消息点对点)协议吗?查了文档,没有找到专门针对 SMPP 的文档。
@ServiceActivator(inputChannel = "[topic].[group].errors") 注释会导致“是否存在无法解析的循环引用异常?”
使用处理本地异常的通道时发生异常,但工作正常。 @ServiceActivator(inputChannel = "force-logout-topic.force-logout-group.errors") 公共空间