问题标签 [spring-integration]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
2 回答
2099 浏览

spring-integration - 尝试使用 Spring Integration 在运行时修改轮询率时出现问题

将通道适配器定义为:

我想知道为什么我不能在运行时修改轮询率,如下:

当我调试这个解决方案时,我可以看到适配器附加了这个新触发器,但是轮询率保持不变(每 5 秒)。我也尝试过 stop() 和 start() 适配器,运气类似。

任何人都可以指出我做错了什么?谢谢

0 投票
1 回答
1901 浏览

spring - 在 Spring JMS 集成中配置基于间隔的 cron

我需要在指定的时间间隔内将消息从 Queue1 转发到 Queue2,而不是在消息到达 Queue1 之后。下面是我的配置。

上面的 xml 配置将消息立即从 Queue1 转发到 Queue2,忽略 <int:poller> 配置。我已经尝试了基于间隔和基于 cron 的解决方案,它们似乎工作相似(立即将消息从 Queue1 传递到 Queue2)。这里的“poller”配置有什么问题吗?任何帮助都感激不尽。

0 投票
2 回答
11708 浏览

spring - Spring 集成:HTTP 入站网关 - 使用 JSON 到 HashMap 的对象转换器

我正在尝试设置基于 Spring 集成的 Restful 服务。我试图避免为请求和响应创建单独的对象,而是将 HashMap 用于简单的功能,例如服务时的isUserAvailableForRegistration

例如

以下是集成相关的上下文信息:

虽然我可以成功测试我可以成功地将 HashMap 编组为 JSON,但我缺少将 JSON 数据解组为 HashMap 的配置。

我得到以下异常:

任何人都可以帮我弄清楚可能出了什么问题吗?

我已经仔细检查了标题,因此我确信这是配置或杰克逊对解组到 HashMap 的支持。谢谢你的时间。

0 投票
1 回答
3319 浏览

header - 在 Spring 集成中获取 JMS 标头

如何在我的 spring 集成 jms 入站通道上获取 JMS 标头?我没有找到关于参考的太多信息。

谢谢并恭祝安康。

0 投票
1 回答
7010 浏览

java - 套接字和 Spring 集成

我有一个监听端口 30003 的小程序。它是一个处理字节流数据的服务器类,如下所示:

这很好用 - 但是我想转向使用 Spring Integration。这是我的 tcp-context 用于实现相同目的的东西:

当我使用 Spring Integration 方法启动程序时,我得到以下堆栈跟踪 - 告诉我套接字地址已在使用中。

我不明白为什么当我的标准套接字程序运行良好时 - 为什么集成方法会失败。我的机器上有一些软件可以在 30003 端口上提供数据。

我希望你能帮忙。

谢谢

0 投票
1 回答
1813 浏览

jms - Spring 集成在出站主题中发布消息

我有弹簧集成管道,应该将消息发布到 ActiveMQ 主题。我正在尝试使用以下配置配置 de spring xml 文件

但消息未发布到主题。您知道如何配置 Spring 集成以将消息发布到 JMS 主题吗?我会期待你的答案。谢谢你,弗洛林

0 投票
1 回答
5481 浏览

gateway - Spring 集成获取 HTTP 出站网关响应

我需要发布一个 REST 服务调用并获取它返回的数据(所有这些都使用 JSON)。我有一个出站网关,它的回复通道作为一个链,并且该链有一个转换器。

但是,当我通过转换器进行调试时,我得到的有效负载只是一个 HttpStatus 对象。

也许我做错了什么?任何帮助将不胜感激。谢谢!

0 投票
1 回答
900 浏览

spring - 当数据库不可用时,弹簧集成防止轮询

我们使用 Spring Integration 2.1 将消息持久化到客户端发送的数据库中。

有一个队列将由自定义适配器填充。配置的服务激活器轮询此队列并将消息发布到 Spring 管理的 @Repository bean。所有错误都将被捕获到错误通道并由服务处理。到目前为止,配置工作正常。

我担心的是,如果数据库不可用,服务激活器会轮询来自队列的所有传入消息并将它们放入错误通道。如果数据库显然不可用,是否有办法阻止服务激活器轮询消息,例如通过发送测试查询?

我的配置:

问候。

0 投票
1 回答
3569 浏览

spring - 使用事务向异步服务发送消息

我有一个持久的事务队列,其中包含我需要通过异步协议发送的消息。每条消息都需要在自己的事务中发送,但是在给定时间正在传输的消息数量排除了使用thread-per-message,而吞吐量要求排除了持久的中间状态。

查看 的代码JmsTransactionManager,我看到它正在使用TransactionSynchronizationManager,它将事务资源存储在ThreadLocal. 所以看来我需要实现一个PlatformTransactionManager以某种方式在一个线程中引导多个事务。这似乎有点极端……

是否有一些 Spring Integration 单元的安排可以避免这种复杂性?我是否应该查看 JTA/XA 信息?

0 投票
1 回答
2450 浏览

spring - 用于 Spring Integration 定义的基于 Java 的容器配置

我以前为我的 Spring 应用程序使用过基于 XML 的配置。

现在,我只想使用 @ Bean、@Configuration 等基于 Java 的容器配置。

如何将这两个 XML 配置转换为基于 Java 的配置?