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>,IntegrationPattern,NamedComponent,IntegrationInboundManagement,IntegrationManagement
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, loggerFields inherited from interface org.springframework.integration.support.management.IntegrationManagement
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME -
Constructor Summary
ConstructorsConstructorDescriptionFeedEntryMessageSource(URL feedUrl, String metadataKey) Creates a FeedEntryMessageSource that will use a HttpURLFeedFetcher to read feeds from the given URL.FeedEntryMessageSource(Resource feedResource, String metadataKey) Creates a FeedEntryMessageSource that will read feeds from the givenResource. -
Method Summary
Modifier and TypeMethodDescriptionprotected com.rometools.rome.feed.synd.SyndEntrySubclasses must implement this method.protected voidonInit()voidsetMetadataStore(MetadataStore metadataStore) voidsetPreserveWireFeed(boolean preserveWireFeed) Specify a flag to indication ifWireFeedshould be preserved in the targetSyndFeed.voidsetSyndFeedInput(com.rometools.rome.io.SyndFeedInput syndFeedInput) Specify a parser for Feed XML documents.toString()Methods inherited from class org.springframework.integration.endpoint.AbstractMessageSource
buildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeMethods inherited from class org.springframework.integration.util.AbstractExpressionEvaluator
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionServiceMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.springframework.integration.support.management.IntegrationManagement
getThisAs, isObserved, registerObservationRegistryMethods inherited from interface org.springframework.integration.core.MessageSource
getIntegrationPatternType
-
Constructor Details
-
FeedEntryMessageSource
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 theResourcevia the alternate constructor.- Parameters:
feedUrl- The URL.metadataKey- The metadata key.
-
FeedEntryMessageSource
Creates a FeedEntryMessageSource that will read feeds from the givenResource.- Parameters:
feedResource- theResourceto use.metadataKey- the metadata key.- Since:
- 5.0
-
-
Method Details
-
setMetadataStore
-
setSyndFeedInput
public void setSyndFeedInput(com.rometools.rome.io.SyndFeedInput syndFeedInput) Specify a parser for Feed XML documents.- Parameters:
syndFeedInput- theSyndFeedInputto use.- Since:
- 5.0
-
setPreserveWireFeed
public void setPreserveWireFeed(boolean preserveWireFeed) Specify a flag to indication ifWireFeedshould be preserved in the targetSyndFeed.- Parameters:
preserveWireFeed- thebooleanflag.- Since:
- 5.0
- See Also:
-
SyndFeedInput.setPreserveWireFeed(boolean)
-
getComponentType
-
onInit
protected void onInit()- Overrides:
onInitin classAbstractExpressionEvaluator
-
doReceive
protected com.rometools.rome.feed.synd.SyndEntry doReceive()Description copied from class:AbstractMessageSourceSubclasses must implement this method. Typically the returned value will be thepayloadof type T, but the returned value may also be aMessageinstance whose payload is of type T; also can beAbstractIntegrationMessageBuilderwhich is used for additional headers population.- Specified by:
doReceivein classAbstractMessageSource<com.rometools.rome.feed.synd.SyndEntry>- Returns:
- The value returned.
-
toString
-