public class FeedEntryMessageSource extends IntegrationObjectSupport implements MessageSource<com.rometools.rome.feed.synd.SyndEntry>
MessageSource will produce individual
SyndEntrys for a feed identified with the 'feedUrl' attribute.EXPRESSION_PARSER, logger| 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.
|
| Modifier and Type | Method and Description |
|---|---|
String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
Message<com.rometools.rome.feed.synd.SyndEntry> |
receive()
Retrieve the next available message from this source.
|
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() |
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskSchedulerpublic FeedEntryMessageSource(URL feedUrl, String metadataKey)
Resource via the alternate constructor.feedUrl - The URL.metadataKey - The metadata key.public void setMetadataStore(MetadataStore metadataStore)
public void setSyndFeedInput(com.rometools.rome.io.SyndFeedInput syndFeedInput)
syndFeedInput - the SyndFeedInput to use.public void setPreserveWireFeed(boolean preserveWireFeed)
WireFeed should be preserved in the target SyndFeed.preserveWireFeed - the boolean flag.SyndFeedInput.setPreserveWireFeed(boolean)public String getComponentType()
IntegrationObjectSupportgetComponentType in interface NamedComponentgetComponentType in class IntegrationObjectSupportpublic Message<com.rometools.rome.feed.synd.SyndEntry> receive()
MessageSourcenull if no message is available.receive in interface MessageSource<com.rometools.rome.feed.synd.SyndEntry>protected void onInit()
throws Exception
IntegrationObjectSupportonInit in class IntegrationObjectSupportException - Any exception.public String toString()
toString in class IntegrationObjectSupport