Java Reference
In-Depth Information">
<beans:bean class="org.springframework.beans.factory.
p:ignoreUnresolvablePlaceholders="true" />
<channel id="inboundTweets" />
<inbound-channel-adapter ref="twitterMessageSource" channel="inboundTweets">
<poller max-messages-per-poll="100">
<interval-trigger interval="10" time-unit="SECONDS" />
input-channel="inboundTweets" ref="twitterMessageOutput" method="announce" />
The bold parts are the only salient bits. As in previous examples, you start by declaring a channel
( "inboundTweets" ). Next, you configure an instance of the custom MessageSource implementation
TwitterMessageSource . Finally, you use Spring Integration's inbound-channel-adapter element to wire
the TwitterMessageSource and a poller element. The poller element is configured to run every 10
seconds, and to consume as many as 100 messages each time it runs. That is, if it runs 10 seconds from
now, it will call read() without pause on the MessageSource implementation until it's given a null value,
at which point it will idle until the scheduler starts the cycle again at the next 10-second interval. Thus, if
you have 100 messages, this will consume all of them as quick as possible. Ideally, all the messages will
be processed before the next scheduled pull occurs.
Search WWH ::

Custom Search