带有轮询器的 Spring 集成出站网关

Question

以下是配置了标头的出站 http 网关，但当我添加轮询器时没有连续触发。它只会被触发一次并停止。

<int:inbound-channel-adapter channel="fooinfotrigger.channel" expression="''">
    <int:poller fixed-delay="5000"></int:poller>
</int:inbound-channel-adapter>

<int:channel id="fooinfo.channel">
    <int:queue capacity="10"/>
</int:channel>

<int:channel id="fooinfotrigger.channel"></int:channel>

<int:chain input-channel="fooinfotrigger.channel" output-channel="fooinfo.channel">       

    <int:header-enricher>
        <int:header name="Authorization" value="...." />
        <int:header name="Content-Type" value="...." />
    </int:header-enricher>

    <int-http:outbound-gateway id="fooHttpGateway"
        url="https://foo.com/v1/services/foo?status=active"
        http-method="GET"
        expected-response-type="java.lang.String"
        charset="UTF-8"
        reply-timeout="5000">
    </int-http:outbound-gateway>

    <int:transformer method="transform" ref="fooResourcesTransformer"/>

</int:chain>

<bean id="fooResourcesTransformer" class="com.foo.FooTransformer" />

Answer 1

fixed-delay 是一个选项，用于确定在上一个任务完成之后的时间。在您的情况下，poll。

既然你确认了它

触发一次并停止。

看起来您没有以某种方式在 dealinfo.channel 上完成您的工作，并且没有将控件返回给 TaskScheduler，因此，不要为其他事情释放线程。

在<chain> 和dealinfo.channel 上的订阅者之后，我们真的应该看到并理解你的逻辑。

或者...也许您的 REST 服务根本不返回响应。独立于reply-timeout="5000"。