public class FastRSSFeedFetcher extends Object implements RSSFeedFetcher
RSSFeedFetcher
for feed retrieval over http
that follows redirects and supports
conditional gets. Will attempt to fetch all feed channels
defined in the provided aggregate feeds
, processing feeds simultaneously. Failures to fetch a feed
result for a given feed channel are logged at ERROR level.RSSFeedFetcher
Constructor and Description |
---|
FastRSSFeedFetcher(info.magnolia.objectfactory.ComponentProvider componentProvider) |
Modifier and Type | Method and Description |
---|---|
Set<AggregateFeed> |
fetchAggregateFeeds(Set<AggregateFeed> aggregateFeeds)
|
protected ExecutorService |
getExecutorService() |
Class<? extends Runnable> |
getFeedChannelFetchTaskClass() |
int |
getShutdownTimeout() |
void |
setFeedChannelFetchTask(Class<? extends Runnable> feedChannelFetchTask) |
void |
setShutdownTimeout(int shutdownTimeout) |
void |
shutdown()
All feeds that are being fetched will be shut down.
|
protected void |
waitForFutureResult(Future<?> future) |
@Inject public FastRSSFeedFetcher(info.magnolia.objectfactory.ComponentProvider componentProvider)
public Set<AggregateFeed> fetchAggregateFeeds(Set<AggregateFeed> aggregateFeeds)
RSSFeedFetcher
fetchAggregateFeeds
in interface RSSFeedFetcher
aggregateFeeds
- the aggregates to fetch feed content for (must not be null)protected void waitForFutureResult(Future<?> future)
public void setFeedChannelFetchTask(Class<? extends Runnable> feedChannelFetchTask)
public void shutdown()
shutdown
in interface RSSFeedFetcher
public int getShutdownTimeout()
public void setShutdownTimeout(int shutdownTimeout)
protected ExecutorService getExecutorService()
Copyright © 2016 Magnolia International Ltd.. All rights reserved.