原因：无法确定回复目的地：请求消息不包含回复目的地，并且未设置默认回复目的地
使用 JMSConfig 我正在创建 MQ 连接工厂，并且我有 InboundGatewayConfig 和 OutboundGatewayConfig ，在入站配置中我从一个队列读取消息有效负载，在…
Spring Integration HttpServerErrorException$InternalServerError：500：超时内未收到回复
我正在尝试使用窃听将一些数据复制到另一个通道。这是我的代码： @Bean public IntegrationFlow flow() { return IntegrationFlows.from(Http.inbound…
春季集成 - 聚合 - 有效载荷不得无效
我有一个服务激活器和一个聚合器，如下所示。某些服务完成其工作并将输出提供给 serviceActivatorInputChannel，然后 serviceActivatorInputChannel …
在与主流程不同的文件中调用子流程时抛出异常
我有一个主要流量，我想调用另一个文件中的另一个流。不幸的是，我不断收到 Dispatcher has no subscribers for channel 'application:recordRequests…
春季集成建议使用基于密钥的查询丰富事件的方式
我想从卡夫卡（Kafka）的数据中阅读，在每个事件中，都会从MongoDB中阅读具有ID和Kafka事件的另一个字段。我一般不知道建议这样做的推荐方法是什么，…
仅基于触发文件指定的文件名的弹簧集成到拾取
使用Spring Integration，我只想从触发文件指定的文件名中拾取文件。 例如，如果出现.batch01-trigger，例如batch01.tar将被 拾取但是我无法应用上述…
Reactive Spring Integration 访问 IntegrationFlow 中间的流量
我已经看到了有关的中间访问通量 public void writeToSolr(IntegrationFlowDefinition flowDefinition) { flowDefinition .bridge(e -> e.reactive(fl…
Spring 集成 - 计划删除消息组
我使用 Spring Integration 聚合器模式并存储在 JdbcMessageStore 中。 我知道 .expireGroupsUponCompletion(true) 和 .expireGroupsUponTimeout(true…
验证器异常 Spring Integration：在验证器中返回错误消息
有人知道我如何返回错误消息吗？我试图在验证器中返回特定的 xml 错误消息。这是我的代码： @Override public void validate(Object target, Errors e…
调度程序没有传出 sftp 通道的订阅者
我正在使用 spring-integration-sftp ，我的目标是将本地文件推送到 SFTP （目前仅此而已，无需确认或其他任何内容）。我的配置如下： @EnableIntegra…
如何停止 spring 集成进程
我有一个 spring 集成 xml 文件，如下所示： 我想引入一种新机制来在用户需要时停止正在运行的进程。我如何包含以下机制：
在 FTP 出站网关中，如何获取“mv”格式中的原始文件名？命令？
首先，我列出了一个工作正常的目录中的文件。列出后，我想将文件移动到另一个也可以工作的目录。但是，保留原始文件名是行不通的。这是我的代码； @Be…
我在客户端收到多个响应
我能够读取服务器的响应，但在客户端收到此消息“无法关联响应 - 没有缓存的待处理回复：localhost:3002:46550:f6234e17-c486-4506-82c8-a757a08ba73d…
