0

さまざまなジョブを実行するために、バッファの実装に取り​​組んでいます。私はSpringベースのプロジェクトに取り組んでいます。目的を達成するために Spring Integration を使用することにしました。SI がどのように機能するかを理解するために、Cafè サンプル プロジェクトを実行しました。

Spring Integration を示すために、実行するジョブを動的に挿入するテーブルを実装しました。このテーブルが「ゲートウェイ」です。次に、ルーターとさまざまなチャネルを構成しました。

私が完全に理解していないのは、「ゲートウェイ」に新しいジョブが存在するかどうかを確認する必要があるポーラー要素です。これは正しいです？

もしそうなら、どうすればポーラーを設定できますか? 前もって感謝します！ここでxmlコード：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
xmlns:int="http://www.springframework.org/schema/integration"
xmlns:int-feed="http://www.springframework.org/schema/integration/feed"
xmlns:int-stream="http://www.springframework.org/schema/integration/stream"
xsi:schemaLocation="http://www.springframework.org/schema/beans
    http://www.springframework.org/schema/beans/spring-beans.xsd
    http://www.springframework.org/schema/integration
    http://www.springframework.org/schema/integration/spring-integration.xsd
    http://www.springframework.org/schema/integration/stream
    http://www.springframework.org/schema/integration/stream/spring-integration-stream.xsd">


<int:gateway id="usersToSend" service-interface="it.stasbranger.spidly.rss.UsersToSend" />


<int:channel id="channel" />

<int:channel id="providers"/>
<int:router input-channel="providers" ref="providerRouter" method="resolveProviderChannel"/>

<int:channel id="twitterChannel">
      <int:queue capacity="10"/>
</int:channel>
<int:service-activator input-channel="twitterChannel" ref="twitterService" method="updateStatusByProfile"/>

<int:channel id="facebookChannel">
      <int:queue capacity="10"/>
</int:channel>
<int:service-activator input-channel="facebookChannel" ref="facebookService" method="updateStatusByProfile"/>

<int:channel id="linkedinChannel">
      <int:queue capacity="10"/>
</int:channel>
<int:service-activator input-channel="linkedinChannel" ref="linkedinService" method="writeSlogan2Linkedin"/>

<bean id="twitterService" class="it.social.TwitterService"/>
<bean id="facebookService" class="it.social.FacebookService"/>
<bean id="linkedinService" class="it.social.LinkedinService"/>

<int:poller id="poller" default="true">

</int:poller>

FB

4

1 に答える 1

2

<gateway/>s はポーリングされず、呼び出し元がゲートウェイを使用してフローにメッセージを「送信」するという点で「メッセージ駆動型」です。

ポーリングのシナリオでは、<int:inbound-channel-adapter/>(ポーラーのスケジュールに従って) メソッドをポーリングして、実行する作業を探す を使用します。

メソッドが null を返す場合、ポーラーは (次のトリガーまで) スリープ状態に戻ります。メソッドが値を返す場合、メッセージはチャネルに送信されます。

于 2013-05-16T15:18:29.447 に答える