Ingesting data
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.
Ingesting data from the RSS feed
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>
Tip
I will show the code and explain what it does, but will not cover each and every tag in detail as they have already been covered in the respective chapters.
Ingesting data from an FTP server
Now, for this to work, you need an FTP server configured. For testing, you can always set up an FTP server locally. Depending on your FTP server location and configuration parameters, set up a session factory:
<...