The rss: component is used for polling RSS feeds. FUSE Mediation Router will default poll the feed every 60th seconds.

Note: The component currently only supports polling (consuming) feeds.

New in FUSE Mediation Router 2.0

rss:rssUri

Where rssUri is the URI to the RSS feed to poll.

FUSE Mediation Router will set the in body on the returned Exchange with a ROME SyndFeed. Depending on the splitEntries flag FUSE Mediation Router will either return a SyndFeed with one SyndEntry or a List of SyndEntrys.

The RSS component ships with an RSS dataformat that can be used to convert between String (as XML) and ROME RSS model objects.

A route using this would look something like this:

from("rss:file:src/test/data/rss20.xml?splitEntries=false&consumer.delay=1000").marshal().rss().to("mock:marshal");

The idea is to be able to use FUSE Mediation Router's lovely built in expressions for manipulating RSS messages. As shown below, an XPath expression can be used to filter the RSS message:

// only entries with Camel in the title will get through the filter
from("rss:file:src/test/data/rss20.xml?splitEntries=true&consumer.delay=100")
    .marshal().rss().filter().xpath("//item/title[contains(.,'Camel')]").to("mock:result");

To merge multiple incoming feeds into a single feed, you can utilize a custom AggregationCollection provided with camel-rss. An example usage would look something like this:

from("rss:file:src/test/data/rss20.xml?sortEntries=true&consumer.delay=50").to("seda:temp");
from("rss:file:target/rss20.xml?sortEntries=true&consumer.delay=50").to("seda:temp");

from("seda:temp").aggregate(new AggregateRssFeedCollection()).batchTimeout(5000L).to("mock:result");

Here we use a Seda queue to gather up entries from two RSS feeds. The entries are then fed into a custom aggregator which combines these entries into a single ROME SyndFeed object.

You can filter out entries quite easily by using XPath as shown in the data format section above. You can also utilize FUSE Mediation Router's Bean Integration to implement your own conditions. For instance, a filter equivalent to the XPath example above would be:

// only entries with Camel in the title will get through the filter
from("rss:file:src/test/data/rss20.xml?splitEntries=true&consumer.delay=100").
    filter().method("myFilterBean", "titleContainsCamel").to("mock:result");

The custom bean for this would be

public static class FilterBean {
    public boolean titleContainsCamel(@Body SyndFeed feed) {
        SyndEntry firstEntry = (SyndEntry) feed.getEntries().get(0);
        return firstEntry.getTitle().contains("Camel");
    }
}