org.springframework.integration.feed.inbound

Class FeedEntryMessageSource

java.lang.Object

org.springframework.integration.util.AbstractExpressionEvaluator

org.springframework.integration.endpoint.AbstractMessageSource<com.rometools.rome.feed.synd.SyndEntry>

org.springframework.integration.feed.inbound.FeedEntryMessageSource

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, MessageSource<com.rometools.rome.feed.synd.SyndEntry>, NamedComponent, BaseSourceMetrics, IntegrationManagement, MessageSourceMetrics

public class FeedEntryMessageSource
extends AbstractMessageSource<com.rometools.rome.feed.synd.SyndEntry>

This implementation of MessageSource will produce individual SyndEntrys for a feed identified with the 'feedUrl' attribute.

Since:

2.0

Author:

Josh Long, Mario Gray, Oleg Zhurakousky, Artem Bilan, Aaron Loes

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.util.AbstractExpressionEvaluator

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Constructor Summary

Constructors

Constructor and Description
FeedEntryMessageSource(Resource feedResource, String metadataKey) Creates a FeedEntryMessageSource that will read feeds from the given Resource.
FeedEntryMessageSource(URL feedUrl, String metadataKey) Creates a FeedEntryMessageSource that will use a HttpURLFeedFetcher to read feeds from the given URL.

Method Summary

Modifier and Type	Method and Description
protected com.rometools.rome.feed.synd.SyndEntry	doReceive() Subclasses must implement this method.
String	getComponentType()
protected void	onInit()
void	setMetadataStore(MetadataStore metadataStore)
void	setPreserveWireFeed(boolean preserveWireFeed) Specify a flag to indication if WireFeed should be preserved in the target SyndFeed.
void	setSyndFeedInput(com.rometools.rome.io.SyndFeedInput syndFeedInput) Specify a parser for Feed XML documents.
String	toString()

Methods inherited from class org.springframework.integration.endpoint.AbstractMessageSource

buildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getMessageCount, getMessageCountLong, getOverrides, isCountsEnabled, isLoggingEnabled, receive, registerMetricsCaptor, reset, setBeanName, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType

Methods inherited from class org.springframework.integration.util.AbstractExpressionEvaluator

afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionService

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.integration.support.management.MessageSourceMetrics

messageCount

Constructor Detail

FeedEntryMessageSource

public FeedEntryMessageSource(URL feedUrl,
                              String metadataKey)

Creates a FeedEntryMessageSource that will use a HttpURLFeedFetcher to read feeds from the given URL. If the feed URL has a protocol other than http*, consider providing a custom implementation of the Resource via the alternate constructor.

Parameters:

feedUrl - The URL.

metadataKey - The metadata key.

FeedEntryMessageSource

public FeedEntryMessageSource(Resource feedResource,
                              String metadataKey)

Creates a FeedEntryMessageSource that will read feeds from the given Resource.

Parameters:

feedResource - the Resource to use.

metadataKey - the metadata key.

Since:

5.0

Method Detail

setMetadataStore

public void setMetadataStore(MetadataStore metadataStore)

setSyndFeedInput

public void setSyndFeedInput(com.rometools.rome.io.SyndFeedInput syndFeedInput)

Specify a parser for Feed XML documents.

Parameters:

syndFeedInput - the SyndFeedInput to use.

Since:

5.0

setPreserveWireFeed

public void setPreserveWireFeed(boolean preserveWireFeed)

Specify a flag to indication if WireFeed should be preserved in the target SyndFeed.

Parameters:

preserveWireFeed - the boolean flag.

Since:

5.0

See Also:

SyndFeedInput.setPreserveWireFeed(boolean)

getComponentType

public String getComponentType()

onInit

protected void onInit()

Overrides:

onInit in class AbstractExpressionEvaluator

doReceive

protected com.rometools.rome.feed.synd.SyndEntry doReceive()

Description copied from class: AbstractMessageSource

Subclasses must implement this method. Typically the returned value will be the payload of type T, but the returned value may also be a Message instance whose payload is of type T; also can be AbstractIntegrationMessageBuilder which is used for additional headers population.

Specified by:

doReceive in class AbstractMessageSource<com.rometools.rome.feed.synd.SyndEntry>

Returns:

The value returned.

toString

public String toString()

Overrides:

toString in class Object