Let's start with the first step, ingestion of data. We have configured two data sources: RSS feeds and an FTP server, let's take a look at these.
The following code snippet is the configuration for a feed adapter; this fetches feed from the configured url
and puts it on the channel:
<int-feed:inbound-channel-adapter id="soJavaFeedAdapterForAggregator" channel="fetchedFeedChannel" auto-startup="true" url="${feeds.url}"> <int:poller fixed-rate="500" max-messages-per-poll="1" /> </int-feed:inbound-channel-adapter>