我可以让轮询者使用WAIT after start()命令启动他的周期吗？

Question

在我的集成流程中，我在某些错误条件下从标准流程更改为错误流程，通过向Control Channel发送启动/停止命令消息来停止standardStateEntryPoint和启动errorStateEntryPoint。

errorStateEntryPoint是这样的：

@Bean
public IntegrationFlow errorStateEntryPoint() {
    return IntegrationFlows.from(
            () -> new GenericMessage<String>(""),
                    e -> e.poller(p -> p.fixedDelay(ERROR_STATE_POLLING))
                    .id("errorStateSourcePollingChannelAdapter")
                    .autoStartup(false))
            .channel("httpOutRequest")
            .get();
}

它有一个固定延迟为5_000 ms的Poller。启动时可识别的生命周期是

send -> wait -> send -> wait etc.

是否有可能有相反的生命周期，从延迟开始？

wait -> send -> wait -> send etc.

Answer 1

我发现的是：

您可以设置轮询器的initialDelay。如果您的轮询器有一个5.000毫秒的周期而没有初始延迟，它是这样工作的：

send -> wait -> send -> wait  etc.

如果您设置与初始延迟相同的5.000毫秒，它将完全按照要求工作：

wait -> send -> wait -> send etc.

初始延迟是设置p.fixedDelay(...)的第二个参数。那么errorStateEntryPoint轮询通道适配器应该是这样的：

@Bean
public IntegrationFlow errorStateEntryPoint() {
    return IntegrationFlows.from(
            () -> new GenericMessage<String>(""),
                    e -> e.poller(p -> p.fixedDelay(ERROR_STATE_POLLING, ERROR_STATE_POLLING))
                    .id("errorStateSourcePollingChannelAdapter")
                    .autoStartup(false))
            .channel("httpOutRequest")
            .get();
}

就这样。