有关Spring Integration项目的问题,请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。
无数据源轮询的MessageChannelPartionHandler堆栈跟踪服务
我们将大量的Spring Batch分区作业从2.2迁移到4.x(XML Configuration Of Partition Jobs)。当我调试分区作业时,我得到了这样的堆栈跟踪:2020-05-13 17:03:38,...。
我试图使用一个void async服务激活器为一个s sqs队列实现一个集成流,但处理逻辑从未被触发。消息在流程中被接收,并成功地转换为...
请帮助我解决这个异常。我在我的Spring Boot Java应用程序中运行这个IMAP电子邮件监听器,以从我的gmail收件箱中检索电子邮件返回IntegrationFlows .from(Mail......)。
Spring Integration中的拆分如何用于Web容器?
我想使用Spring Integration来处理HTTP入站消息。我知道,Spring Integration通道会运行在一个容器线程上,但如果我想使用split,会使用什么线程?
我使用Spring Boot 2.3.0版本和Spring Integration 5.3.0,但不知为何我无法让下面的代码工作。
如何使用spring集成将邮件存储到数组列表对象或数据库中?
我需要将邮件保存到一个集合对象或数据库中,以便进行邮件处理。以下是可以显示邮件的代码,谁能指导一下将邮件保存到收集对象(ArrayList)或数据库中,我需要将邮件保存到收集对象或数据库中,以便进行邮件处理。
我正在寻找一个关于如何通过根流连接不同集成流的组件。我看过这个教程(见5.2.Bridge);它有一个主根流,然后是两个不同的流。我试过...
我必须改变Spring Integration(4.3.12, Java DSL)中的一个现有流程。有一个现有的SOAP调用,之后,我必须插入一个新的SOAP调用(它是完成),如果现有的SOAP调用是不是 ...
我和我的一个同事发生了争执。考虑到 "应该使用组成而不是继承",你觉得下面2个代码片段哪个更好?1)class ...
有什么方法可以通过spring集成获得流的状态(也许像,运行,停止,停止与异常)?
最近,我试图建立一个休息服务来创建、启动和停止一个集成流(它是读取一个RSS feed并在控制台打印),我能够实现这一点。但是我的下一个...
I hava xml that include this :
IntegrationFlowDefinition.aggregation不起作用。也许CorrelationStrategy失效了?
错误信息。原因是: java.lang.IllegalStateException: Null correlation not allowed. 也许是CorrelationStrategy失败了?我的实现,@Bean public IntegrationFlow start() { ...
在errorHandler中处理异常后,如何在Controller或Route中获取错误信息?
我不得不自定义Sftp Inbound默认处理程序LoggingHandler,并使用我自己的CustomizedErrorHandler扩展ErrorHandler。但是在处理完后,我不能返回任何消息给我的控制器... ...
Spring Integration DSL的EnrichedHeaders没有被替换。
使用 Boot 2.2.6 和 SI 5.2.5,我试图用一个对象来丰富报头。然而,在流程的第二次传递中,新的报头确实包含了一个新的消息 UUID(所以我知道这是一个新的报头),...。
我最近有一个类似下面的场景。 Flow_B应传递messageA+messageB......。
使用Spring Integration的Java邮件监听器:多个应用程序实例无法接收邮件。
我在一个Springboot应用程序中使用了以下代码。@Bean public IntegrationFlow mailListener() { return IntegrationFlows.from(Mail.imapInboundAdapter(receiver()), e -> e.poller(Pollers......)。
我目前正在使用一个TcpNioClientConnectionFactory来建立一个TCP连接到一个所需的主机。我需要能够在建立连接接受后执行一些操作......
我下载了hibernate 5.4.4 final版本,在eclipse中,我在路径中建立了这些jar,但没有hibernate validator jar,我需要它,谁能给我建议,我需要哪个版本......
假设我的应用程序有以下2个流。@Bean IntegrationFlow flow1() { return IntegrationFlows.from(()-> LocalDateTime.now(), c -> c.poller(Pollers.fixedDelay(...)。
我正在使用Spring集成与DSL,我需要为不同的通道路由消息。简单地说,如果失败,它们应该进入一个输出通道,如果成功,它们应该进入其中一个 ...