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 SyndEntry
s for a feed identified with the 'feedUrl'
attribute.- Since:
- 2.0
- Author:
- Josh Long, Mario Gray, Oleg Zhurakousky, Artem Bilan, Aaron Loes, Christian Tzolov
-
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
ConstructorDescriptionFeedEntryMessageSource
(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.SyndEntry
Subclasses must implement this method.protected void
onInit()
void
setMetadataStore
(MetadataStore metadataStore) void
setPreserveWireFeed
(boolean preserveWireFeed) Specify a flag to indication ifWireFeed
should be preserved in the targetSyndFeed
.void
setSyndFeedInput
(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, 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.IntegrationManagement
getThisAs, isObserved, registerObservationRegistry
Methods 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 theResource
via the alternate constructor.- Parameters:
feedUrl
- The URL.metadataKey
- The metadata key.
-
FeedEntryMessageSource
Creates a FeedEntryMessageSource that will read feeds from the givenResource
.- Parameters:
feedResource
- theResource
to 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
- theSyndFeedInput
to use.- Since:
- 5.0
-
setPreserveWireFeed
public void setPreserveWireFeed(boolean preserveWireFeed) Specify a flag to indication ifWireFeed
should be preserved in the targetSyndFeed
.- Parameters:
preserveWireFeed
- theboolean
flag.- Since:
- 5.0
- See Also:
-
SyndFeedInput.setPreserveWireFeed(boolean)
-
getComponentType
-
onInit
protected void onInit()- Overrides:
onInit
in classAbstractExpressionEvaluator
-
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 thepayload
of type T, but the returned value may also be aMessage
instance whose payload is of type T; also can beAbstractIntegrationMessageBuilder
which is used for additional headers population.- Specified by:
doReceive
in classAbstractMessageSource<com.rometools.rome.feed.synd.SyndEntry>
- Returns:
- The value returned.
-
toString
-