spring-integration 相关问题

有关Spring Integration项目的问题,请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。

Spring集成+文件读取消息源_入站通道适配器+出站网关。

对于文件读取消息源的Inbound Adapter和带有注解的Transformer配置如下 @Bean @InboundChannelAdapter(autoStartup = "false", value = "incomingchannel", poller = @....

回答 1 投票 0

_abc.txt

入站通道适配器是通过一个轮询器来轮询存在于根目录及其子目录中的文件,例如:RootDir。

回答 1 投票 0

Spring Integration JMS--Spring代码在RuntimeException时提交了。

我想请教有经验的Spring集成开发者甚至代码作者,关于我的代码遇到的奇怪行为。问题是Spring代码在我的代码上执行COMMIT ...

回答 1 投票 0

Spring JDBC出站网关返回原始有效载荷。

使用JdbcOutboundGateway,如何让回复是原始payload?目前,响应的payload是{UPDATED=1}。无论是参考文档(Spring 5.2.x)还是源代码似乎都没有提供...

回答 1 投票 0

Spring集成 - 如何使消息在jdbc消息存储区中存活,以防发生错误或在消费处理程序中关闭。

我有一个将消息存储到jdbc消息存储的流程: ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... ... .handle(MessageHandler { Thread.sleep(3000); ...

回答 1 投票 0

如何为Spring Integration中的Rabbit MQ消息监听器执行严格的排序?

我有一个Spring集成项目,我从RabbitMQ队列中发送和接收消息。系统发布消息的顺序是确定的,但之后接收消息的顺序......。

回答 1 投票 0

Spring集成SFTP按需删除远程文件

当我的应用中发生某件事情时,我试图从远程SFTP桶中删除一个文件(我们将文件保存到blob存储)。我一直没能做到这一点。我所能做的就是...

回答 1 投票 0

如何使用 IntegrationFlowContext 作为流程配置的一部分?

作为spring-boot流程配置的一部分,我创建了多个非常相似的集成流。我目前的配置代码看起来像下面。@Configuration public class MyConfig { @Component ...

回答 1 投票 1

如何按规范订阅不同的通道?

我正在寻找一个Spring IntegrationFlows中的切换操作符。我需要根据用户可以决定的属性来订阅一个通道。@Bean public IntegrationFlow flow() { ...

回答 1 投票 0

原因:java.lang.ClassNotFoundException:org.springframework.batch.integration.partition.BeanFactoryStepLocator。

我正在研究Spring Boot+Spring Batch的例子,在这个例子中,我只是简单地更新了Spring Boot到2.2.6.RELEASE。在这个例子中,我只是简单地将Spring Boot更新到2.2.6.RELEASE。然后突然应用程序就中断了。代码灵感来自:https:/github.com...。

回答 1 投票 0

Spring Integration Mail IMAP支持OAuth2吗?

我正在使用Spring集成邮件来处理imap idle事件。我想用token实现IMAP gmail客户端,而不是使用用户名和密码。Spring Integration Mail IMAP是否能够连接...

回答 1 投票 0

如何将消息推送到google cloud pubsub后返回响应到webflux端点?

我正在使用spring integration创建一个简单的spring boot应用程序。以下是这个应用程序的三个主要结构。Inbound Gateway: WebFluxInboundEndpoint接受http请求 出站网关: ...

回答 1 投票 1

Spring Integration - 将XML有效载荷转换为JSON。

我正在创建一个通用的适配器,它将接受XML消息(带有namepace)并将其转换为JSON。我可以使用xslt删除命名空间,然后使用org.json api转换为JSON,有 ...

回答 1 投票 0

在Spring Integration的多个IntegrationFlows中重用SimpleWebServiceOutboundGateway。

考虑到我有2个集成流引用同一个SimpleWebServiceOutboundGateway bean。@Bean IntegrationFlow getDataA( Jaxb2Marshaller xmlMarshaller, ...

回答 1 投票 0

春天集成事件的春天集成顺序

我正在处理Spring集成事件,需要确保事件调用的正确顺序。我有两个监听器。其中一个叫终端错误监听器(TerminalErrorListener),负责捕获TcpConnectionExceptionEvent和 ...

回答 1 投票 0

Spring Integration TCP Inbound Adapter客户端断线问题

我们为一个入站的TCP服务器创建了一个IntegrationFlow。每当我们测试时,集成都很好,直到客户端断开连接,然后我们得到一个连续的空消息流。Spring ...

回答 1 投票 0

如何在Spring集成中向自定义错误通道直接发出异常?

我在SAP Commerce (hybris)中设置了一个带有自定义错误通道的自定义热文件夹,但我无法让Spring调用我的自定义错误处理程序NviMediaErrorHandler。这是hot-folder-spring.xml中的设置......

回答 1 投票 0

Spring集成写到IBM MQ

使用Boot 2.2.2和Spring Integration 5.2.2通过IBM MQ Series 9与另一个应用程序交互;消息需要是纯文本(不是JMS)。SI可以正确获取文本消息,但是我...

回答 1 投票 1

Spring Integration Transform故障回滚JMS,未转发到错误通道

使用Boot 2.2.2和Integration 5.2.2--当XML消息从一个文件中获取,并且未能解开marshalling(即它不是XML)时,消息会像预期的那样进入errorChannel。然而,当...

回答 1 投票 0

Pub-Sub错误处理策略

这是我的通道设置。一个jdbc消息存储支持的队列 一个连接队列和pub-sub通道的桥接 pub-sub通道上配置的轮询器是事务性的 现在当有一个... ...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.