public class MentionsReceivingMessageSource extends IntegrationObjectSupport
EXPRESSION_PARSER, logger
Constructor and Description |
---|
MentionsReceivingMessageSource(org.springframework.social.twitter.api.Twitter twitter,
java.lang.String metadataKey) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
long |
getLastProcessedId() |
protected int |
getPageSize() |
protected org.springframework.social.twitter.api.Twitter |
getTwitter() |
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
protected java.util.List<org.springframework.social.twitter.api.Tweet> |
pollForTweets(long sinceId)
Subclasses must implement this to return tweets.
|
org.springframework.messaging.Message<?> |
receive()
Retrieve the next available message from this source.
|
void |
setMetadataStore(MetadataStore metadataStore) |
void |
setPageSize(int pageSize)
Set the limit for the number of results returned on each poll; default 20.
|
void |
setPrefetchThreshold(int prefetchThreshold) |
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
public MentionsReceivingMessageSource(org.springframework.social.twitter.api.Twitter twitter, java.lang.String metadataKey)
public java.lang.String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class IntegrationObjectSupport
protected java.util.List<org.springframework.social.twitter.api.Tweet> pollForTweets(long sinceId)
sinceId
- The id of the last reported tweet.public void setMetadataStore(MetadataStore metadataStore)
public void setPrefetchThreshold(int prefetchThreshold)
protected org.springframework.social.twitter.api.Twitter getTwitter()
protected int getPageSize()
public void setPageSize(int pageSize)
pageSize
- The pageSize.protected void onInit() throws java.lang.Exception
IntegrationObjectSupport
onInit
in class IntegrationObjectSupport
java.lang.Exception
- Any exception.public org.springframework.messaging.Message<?> receive()
MessageSource
null
if no message is available.receive
in interface MessageSource
@ManagedAttribute public long getLastProcessedId()
-1
if lastProcessedId is not set, yet.