问题标签 [spring-dsl]

我有一个适用于队列通道的 dsl 流。但是，当我使用 Rendezvous 通道使其同步时，我得到的确认速率最多为 30 条消息/秒。我的处理程序只需 350 微秒即可完成该过程，但确认率一直很低。这大大增加了兔子队列。我什至将并发消费者扩展到 10 个并增加了预取，但这并没有帮助。然后我自己添加了几个更缩放的实例，但这有助于将 ack rate 提高到 45/sec 左右。

我怎样才能让流确认更快？我预计每秒超过 500 个的速率。

DSL流：

同步频道：

容器：

重试恢复建议：

轮询器：

我正在开发一个简单的处理器来验证路由中是否存在强制属性。在调用处理器之前，我需要在路由定义中添加该列表。

我的处理器是：

}

当我尝试调用这条路线时，我得到：

有可能在 XML 中实现这一点吗？

请找到以下路线程序，

在这个 from Xpath 表达式中，我按预期将PurchaseOrderNumber设为152346。现在我将 152346 设置为标头中的变量 body 并将其作为输入发送到名为 Ship 的脚本。

但这是我没有得到 152346 作为我的脚本的价值。它是空的。

请让我知道如何将 152346 值设置为标题并将其作为输入传递给我的脚本。

我的脚本将 152346 作为输入。

我有这样的 PublishSubscribeChannel：

我也有订阅者频道：

最后是另一个订阅者：

问题是，当我从另一个流程中调用方法名称为“publishAction”的频道时，它只打印“ANOTHER CHANNEL HERE”并忽略其他订阅者。但是，如果我用 调用 .channel("publishCha.input")，这次它会进入 publishCha 和 publishCha2 订阅者，但会忽略第三个订阅者。

我的问题是，为什么这两种不同的引导方法会产生不同的结果？

编辑：narayan-sambireddy 询问我如何向频道发送消息。我通过网关发送它：

在主要：

Spring Integration DSL 的文件写入支持是否有任何工作示例？我找不到有关 DSL 实现的任何信息。（例如，集成流程中的 handle() 步骤等）谢谢。

以下是我用于 pop3 连接的 spring 配置 bean，

还仔细检查了看起来不错的凭据。得到以下异常，

2018-06-22 19:27:54.351 错误 2092 --- [ask-scheduler-2] osintegration.handler.LoggingHandler：org.springframework.messaging.MessagingException：轮询邮件时发生故障；嵌套异常是 javax.mail.AuthenticationFailedException: 在 org.springframework.integration.endpoint.SourcePollingChannelAdapter.receiveMessage(SourcePollingChannelAdapter.java:224) 在org.springframework.integration.endpoint.AbstractPollingEndpoint.doPoll(AbstractPollingEndpoint.java:245) 在 org.springframework.integration.endpoint.AbstractPollingEndpoint.access$000(AbstractPollingEndpoint.java:58) 在 org.springframework.integration.endpoint.AbstractPollingEndpoint$1。

有人可以帮我用线程池重写这个流程吗？以下代码有效，但使用固定延迟来服务传入文件：

需要线程，因为文件的速度很快。

具有错误通道和默认请求通道的 int:gateway 的 Java DSL 等效项是什么。默认请求通道输入到转换器，该转换器将 JMS 消息发送到出站适配器并返回可侦听的未来。

我正在使用 Spring DSL 来访问网络服务器，就像这样，

<!-- 1 -->当端点命中时， <!-- 2 -->向 Web 服务器发送请求，<!-- 3 -->检查作为响应从 Web 服务器接收的根元素，基于该响应 XML 将发送到另一个端点

Webserver 将返回 2 个 XML 消息中的任何一个，例如，

或者

从 Web 服务器接收到 XML 后，需要检查根目录是否会对接收到的 XML 执行不同的操作，

参考了一些网站后，我才知道XPath在spring DSL可以用于条件，

我的问题： 1. 仅从响应 XML 中检索根标记名称（如下所示）并根据 XPath 检查对原始响应 XML 执行不同的操作

tns:Parenttag xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance xmlns:tns="http://example.com" ==> Parenttag

或者

tns:roottag xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance xmlns:tns="http://example.com" ==> roottag

我在 JBoss EAP 6.4 上使用 Apache Camel 和 JBoss Fuse 6.3。我想通过 Spring DSL 访问环境属性（例如 JBoss Fuse 主位置），但出现错误：使用以下代码

我收到此错误

换JBOSS_FUSE_HOME家JBOSS_EAP解决不了

问题是什么？