public class FeedEntryMessageSource
extends org.springframework.integration.context.IntegrationObjectSupport
implements org.springframework.integration.core.MessageSource<com.sun.syndication.feed.synd.SyndEntry>
MessageSource
will produce individual
SyndEntry
s for a feed identified with the 'feedUrl' attribute.Constructor and Description |
---|
FeedEntryMessageSource(java.net.URL feedUrl,
java.lang.String metadataKey)
Creates a FeedEntryMessageSource that will use a HttpURLFeedFetcher to read feeds from the given URL.
|
FeedEntryMessageSource(java.net.URL feedUrl,
java.lang.String metadataKey,
com.sun.syndication.fetcher.FeedFetcher feedFetcher)
Creates a FeedEntryMessageSource that will use the provided FeedFetcher to read from the given feed URL.
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getComponentType() |
protected void |
onInit() |
org.springframework.messaging.Message<com.sun.syndication.feed.synd.SyndEntry> |
receive() |
void |
setMetadataStore(org.springframework.integration.metadata.MetadataStore metadataStore) |
afterPropertiesSet, getApplicationContext, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString
public FeedEntryMessageSource(java.net.URL feedUrl, java.lang.String metadataKey)
FeedFetcher
via the alternate constructor.feedUrl
- The URL.metadataKey
- The metadata key.public FeedEntryMessageSource(java.net.URL feedUrl, java.lang.String metadataKey, com.sun.syndication.fetcher.FeedFetcher feedFetcher)
feedUrl
- The URL.metadataKey
- The metadata key.feedFetcher
- The feed fetcher.public void setMetadataStore(org.springframework.integration.metadata.MetadataStore metadataStore)
public java.lang.String getComponentType()
getComponentType
in interface org.springframework.integration.support.context.NamedComponent
getComponentType
in class org.springframework.integration.context.IntegrationObjectSupport
public org.springframework.messaging.Message<com.sun.syndication.feed.synd.SyndEntry> receive()
receive
in interface org.springframework.integration.core.MessageSource<com.sun.syndication.feed.synd.SyndEntry>
protected void onInit() throws java.lang.Exception
onInit
in class org.springframework.integration.context.IntegrationObjectSupport
java.lang.Exception