2

この構成は正常に機能しますが、15秒ごとにポーリングすることになっているinbound-channel-adapterが継続的に実行されています。誰かが私が間違っていることを知っていますか?

<si:channel id="msgChannel" />

    <si:inbound-channel-adapter ref="jdbcInputAdapter"
        method="fetchData" channel="msgChannel">
        <si:poller>
            <si:interval-trigger interval="15000" />
        </si:poller>
    </si:inbound-channel-adapter>

    <si:outbound-channel-adapter ref="shouter"  method="shout" channel="msgChannel"/>
4

1 に答える 1

3

ポーラーはデフォルトで、各ポーリングのチャネルまたはソースからすべてのメッセージを取得します。max-messages-per-pollこれはアトリビュートで微調整できます。これを 1 に設定すると、期待どおりの動作が得られます。

于 2010-05-13T07:08:58.653 に答える