spring-integration - Spring 集成 - 带有轮询器的 @ServiceActivator
问题描述
我正在研究基于注释的 Spring 集成项目。我尝试使用 Poller 编写 @ServiceActivator,但问题是消息轮询恰好发生 3 次然后停止。这里可能是什么问题?
相同的轮询与@InboundChannelAdapter 一起工作得很好,但只是想知道为什么它不能与ServiceActivator 一起工作。
@ServiceActivator(inputChannel = "inputChannel", outputChannel = "outputChannel", poller = @Poller(fixedDelay = "5000"))
解决方案
通常,当您持有轮询线程时会发生此错误。你可能在中间有一些网关(在下游的某个地方outputChannel
)需要一些回复,但你没有发送一个。如果没有应用程序的更多配置,很难说发生了什么。
之后的整个流程是outputChannel
什么?