有关Spring Integration项目的问题,请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。
Spring集成中的MutableMessageBuilderFactory
我有一个春季云流消费者,从卡夫卡那里获取消息。我想修改消息头,但当前收到的消息类型为GenericMessage。我看到了这篇文章和这段代码,来自...
Spring Service Activator-我们可以对Java中两个不同的输入通道使用带ref的相同方法吗?
我们有通用代码来执行相同的逻辑,但输入通道将不同。参见示例
Spring Integration 5.2.2.RELEASE-使用@IntegrationConverter进行集成流转换不适用于杰克逊数据绑定
我将Spring Boot版本从2.1.8.RELEASE升级到2.2.2.RELEASE(因此Spring Integration从5.1升级到5.2.2.RELEASE),并且如果..,使用@IntegrationConverter的自动投射似乎不再起作用。 。
我正在运行一个邮件imapInboundAdapter的示例:@Bean public IntegrationFlow mailListener(){return IntegrationFlows.from(Mail.imapInboundAdapter(“ imaps:// myemailt%40mail ....
如何在同一应用程序中更好地关联Spring Integration TCP入站和出站适配器?
我目前有一个Spring Integration应用程序,该应用程序利用许多TCP入站和出站适配器组合进行消息处理。所有这些适配器组合都使用相同的...
我有用于FTP的Spring入站,我正在查看文档https://docs.spring.io/spring-integration/reference/html/ftp.html。如果您碰巧在本地本地存储了一个或多个文件, ...
防止执行发送方通道,直到在Spring Integration中从拆分器完成处理中生成执行程序通道为止
当前,我的程序正在以单线程方式执行,在该程序中,它会遍历上下文文件并发出各种HTTP请求,并且来自HTTP请求的响应将用于创建...
[我有一个类似FTP的文件的要求,将文件复制到本地目录,将文件拾取到服务器1进行解析和读取服务2,以丰富XYZ服务3,以丰富CDY服务4,以持久保存...]]
是否可以在执行期间在Spring Integration中添加路由?我在Spring Boot中进行项目,我需要使用Spring Integration使路由能够在运行时创建。我找不到...
Spring Integration-如何以编程方式使用uri param / url表达式?
我必须为以下步骤编写Spring Integration流程:(1)从目录读取json文件(2)转换为Java对象并添加标头(3)转换为JSON(4)发布到结束点:POST .. 。
有没有一种方法可以在春季云流中不使用实际消息代理的情况下进行具有多个通道的集成测试?
我们在同一应用程序中将Spring云流与多个处理程序一起使用,我们正在尝试创建集成测试。很少有以下处理程序:公共接口Source1 ...
Spring集成-@ServiceActivator with Poller
我正在基于注释的Spring集成项目中工作。我试图用Poller编写@ServiceActivator,但是问题是消息轮询发生了3次,然后停止。 ...
最初,我们通过google Pub / Sub进行免疫的流程是:应用程序接受消息,检查它是否在idempotencyStore 3.1中不存在-如果不存在-放入幂等性存储(...
如何要求Spring为JdbcMetadataStore创建相应的架构?
我想使用在此描述的jdbc元数据存储:https://docs.spring.io/spring-integration/docs/5.2.0.BUILD-SNAPSHOT/reference/html/jdbc.html#jdbc-metadata-store quote:组织。...
如何在Spring Integration中在运行时解决jms出站目标队列,
因此,目标队列由MSG_TYPE从源目录中的.txt文件确定,该目录是集成流程的源。如果MSG_TYPE以“ ORU”开头,则发送到队列“ jms / dataqueue”,如果...
Spring集成-@InboundChannelAdapter轮询
我是Spring Integration的新手。我们正在使用Spring Integration Annotations创建应用程序。我已经配置了@InboundChannelAdapter,轮询器的固定延迟为5秒。但是问题是...
在确认[Heisenbug]后一次又一次从Google Pub / Sub订阅接收到消息
我想注意到,我将描述的场景发生得很少,并且在大多数情况下,一切都按预期进行。我在发布/订阅方面有1个主题和1个订阅。我的Java应用程序...
如何限制与TcpNioServerConnectionFactory上的单个客户端的连接?
我目前有一个Spring Integration应用程序,该应用程序将许多TCP入站和出站适配器组合用于消息处理。这些组合中的每个入站适配器都使用...