问题标签 [spring-integration-dsl]

我可以配置一个JmsMessageDrivenChannelAdapter，以便它能够与不同的目的地一起工作，通过DestinationResolvers或这样吗？我想通过IntegrationFlows构建器提供目标逻辑，所以我可以重用组件（我不需要为每个主题创建一个适配器），或者将所有目标源/决策规则集中在一个类中

我目前是我们正在使用 Spring 集成的项目的一部分。为了使 queuechannel 持久化，我们计划使用 jdbcmessagestore。但无法找到任何 java 配置或任何方法作为 queuechannel 的一部分来添加消息存储，如 xml 配置中所示。

任何帮助将不胜感激。

我正在尝试将我的一些代码从 XML 迁移到 java dsl 样式（java8 之前）。

这是我创建的 java 配置，我无法弄清楚如何设置轮询器。这些示例仅讨论全局轮询器，但在我的情况下，我需要在适配器中设置轮询器。

我拥有的 XML 等价物如下：

看起来在 Spring 消息传递抽象 ( ) 而不是 JMS ( ) 中没有用于构建messageDrivenChannelAdapter, ... 的工厂。listenerContainersorg.springframework.messaging.*org.springframework.jms.*

我的意思是，您可以配置消息传递MappingJackson2MessageConverter而不是 JMS，使用JmsMessagingTemplate...

在拆分器之后，处理消息时发生异常。我想处理该异常并将一条新消息定向到公共通道，该消息具有产生异常的该消息的相关 id 和一个指示错误的特殊标头。

我试过这样：

但聚合器返回此错误：

我无法在邮件标题中复制相关 ID。

有谁知道我做错了？提前致谢。

在集成流中，使用其默认策略的拆分从列表中发出一个项目。该项目的处理可能会失败。我想处理该错误并将带有映射信息的新消息从前一个消息（除了自定义错误标头）定向到正常消息传递通道。

在聚合器中，我想自定义聚合逻辑以生成其他类型的消息，其中包含失败进程的计数和未失败消息的结果。

在这里，我解释了如何发送带有标头的错误消息：

我希望聚合器生成这种类型的对象：

我应该如何处理这个？

提前致谢。

感谢 Artem 的帮助，我做了这个实现：

我是 Spring Integration 的新手，我必须从 3rd 方 Web 服务获取在线代理列表，我尝试配置 Spring Integration 来获取它，但就channel部分而言，我不确定如何配置它。

我的原始配置如下，我从用于向 3rd 方 Web 服务发送请求的示例中复制：

在我的集成配置中，

问题是，我没有向 web 服务发送任何参数，requestChannel它迫使我这样做，所以我修改了gateway部分：

这部分保持不变：

它提示我java.lang.IllegalStateException: receive is not supported, because no pollable reply channel has been configured，为什么我不能MessageChannel用作回复频道？我应该如何配置IntegrationConfiguration？

什么是 Spring Integration DSL 创建等价物的方式

我无法找到工厂，org.springframework.integration.dsl并且没有任何参数列表IntegrationFlows.from(...)有助于自我发现。

感觉就像我缺少来自https://github.com/spring-projects/spring-integration-java-dsl/wiki/Spring-Integration-Java-DSL-Reference#using-protocolJava的协议适配器之类的东西-适配器。

我遇到的唯一一件事是在一篇旧的博客文章中，但它似乎需要用@MessagingGatewayand注释界面@Gateway，我想避免这种情况。见https://spring.io/blog/2014/11/25/spring-integration-java-dsl-line-by-line-tutorial

我不知道这个问题是关于 spring-integration、spring-integration-dsl 还是两者都有，所以我只添加了 2 个标签...

今天花了不少时间，先用过滤器做一个简单的流程

消息过滤器是消息选择器的一个非常简单的实现。到目前为止一切顺利，没有花太多时间。但是后来我想记录一条消息，以防 MessageSelector 返回错误，这就是我卡住的地方。

很长一段时间后，我最终得到了这个：

这既丑陋又冗长，所以问题是，我在这里做错了什么，我应该如何以更好、更清洁、更优雅的解决方案来做呢？

干杯。

我有一个入站 http 网关，其传入消息被传递到出站 http 网关（使用集成 java dsl）。

当出站网关响应的 http 状态为 200 时，出站响应按预期返回到入站网关的调用方。

但是，当出站网关响应特定客户端错误（如 423 锁定或 403 禁止）时，入站网关的调用方会收到 500 和包含异常字符串的正文消息。

我知道这是因为 SI 将出站 http 错误作为异常处理。但在我的情况下，我需要将错误状态和出站响应附带的响应正文传递回入站网关的调用者，以获得特定的错误代码。我怎么做？