等待 Spring Integration 中的所有线程完成
我有一个自动执行的 jar 程序,它严重依赖 Spring Integration。我遇到的问题是程序在其他 Spring bean 完全完成之前终止。 下面是我正在使用的代码的…
Spring Integration 2 与 Quartz 调度程序
我是 Spring 集成的新手。 我已经配置了一个 Spring 文件 inbound-channel-adapter,例如 现在工作正常。 但这需要部署在集群环境中。我想确保集群中…
使用 xpath 获取 xsi:type 的值
我正在尝试确定正确的 XPath 表达式以返回 Body 元素上的 xsi:type 属性的值。我已经尝试了似乎所有的事情,但没有运气。根据我读到的内容,这似乎很…
Spring 集成 - 配置 DefaultMessageListenerContainer 来解析多个目的地
我需要配置 DefaultMessageListenerContainer 来解析多个目标主题。我不想实例化多个容器,我想知道如何配置它,或者即使它是可能的。 谢谢…
使用 Spring Batch 读取一条记录/项目并写入多条记录/项目
我做了一些搜索,但找不到任何示例/示例。 我有一个要求,从一个表(输入)读取地理坐标,进行处理以生成与坐标关联的 POI。因此,一个地理坐标将产生…
Spring Integration - http 出站网关自定义标头
我有 java 对象,我想将其作为自定义标头传递到 http 出站网关上的请求。下面是一个片段
异步处理电子邮件中的附件(Spring Mail Integration)
如果我有一个带有邮件服务器入站通道的 Spring 应用程序,那么处理每封电子邮件中的每个文件的最佳方法是什么(我大约每 1 分钟轮询一次,并获取 1 封…
SpringIntegration消息大小太大,如何拆分
我有一个带有 JMS 端点的 SprintIntegration 系统。消息的大小限制为 4mb。我的结果比这个大,我如何让 SI 将其分成几条消息? /一个…
概括 http:outbound-gateway 回复通道
给定一个处理对 ws.service 的服务调用的网关。我的目标是使用 header-enricher 提供 http:outbound-gateway 的回复通道,因为我将向 gateway 添加多…
Spring Integration JMS 出站适配器事务控制
为了在启用事务的情况下使用jms实现消息的高性能生产,需要控制每个事务发送的消息量,数量越大性能越高, 是否可以通过以下方式控制事务:弹簧集成?…
如何使用 Spring Integration 2.0.5 根据内容路由消息?
我开始使用 si-xml:xpath-router 但遇到了障碍。我是否使用了正确的路由器但实施错误?如果我使用的路由器不正确,我应该使用哪一个,即默认路由器、…
Spring Integration:使用聚合后再次拆分消息?
在我的 Spring Integration 支持的项目中,我有一个分离器和有效负载路由器,用于将数据发送到各种变压器。然后,新的“转换后”对象被传回聚合器并进…
spring poller 针对 jdbc 支持的队列通道 - 集群模式
在下面的场景中,一条消息会被处理两次(意味着在超过 1 个集群节点中)吗? 1. 包含待处理消息的 jdbc 消息存储支持的队列通道 2. 在消息消费者端配…