org.springframework.integration.x.twitter

Class TwitterStreamChannelAdapter

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.endpoint.AbstractEndpoint

org.springframework.integration.endpoint.MessageProducerSupport

org.springframework.integration.x.twitter.TwitterStreamChannelAdapter

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.integration.context.NamedComponent, org.springframework.integration.core.MessageProducer, org.springframework.integration.history.TrackableComponent

public class TwitterStreamChannelAdapter
extends org.springframework.integration.endpoint.MessageProducerSupport

Message producer which reads form Twitter's public stream endpoints. Unless filtering parameters are set, it will read from the statuses/sample.json endpoint, but if any of the track, follow or locations parameters are set, it will switch to using statuses/filter.json. Apart from the read and connection timeouts, the available parameters map directly to those defined for the public streams API.

Author:

Mark Fisher, Luke Taylor

Field Summary

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

logger

Constructor Summary

Constructors

Constructor and Description
TwitterStreamChannelAdapter(org.springframework.social.twitter.api.impl.TwitterTemplate twitter)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doStart()
protected void	doStop()
java.lang.String	getComponentType()
void	setConnectTimeout(int millis) The connection timeout for making a connection to Twitter.
void	setDelimited(boolean delimited) Whether "delimited=length" shoud be added to the query.
void	setFilterLevel(java.lang.String filterLevel) One of "none", "low" or "medium"
void	setFollow(java.lang.String follow) Restrict the stream to a user or users.
void	setLanguage(java.lang.String language) Filter tweets by language or languages.
void	setLocations(java.lang.String locations) Bound the returned tweets by location(s).
void	setReadTimeout(int millis) The read timeout for the underlying URLConnection to the twitter stream.
void	setStallWarnings(boolean stallWarnings) Whether "stall_warnings=true" should be added to the query.
void	setTrack(java.lang.String track) Filter tweets by words or phrases.

Methods inherited from class org.springframework.integration.endpoint.MessageProducerSupport

onInit, sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrack

Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint

getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.integration.context.NamedComponent

getComponentName

Constructor Detail

TwitterStreamChannelAdapter

public TwitterStreamChannelAdapter(org.springframework.social.twitter.api.impl.TwitterTemplate twitter)

Method Detail

setReadTimeout

public void setReadTimeout(int millis)

The read timeout for the underlying URLConnection to the twitter stream.

setConnectTimeout

public void setConnectTimeout(int millis)

The connection timeout for making a connection to Twitter.

setDelimited

public void setDelimited(boolean delimited)

Whether "delimited=length" shoud be added to the query.

setStallWarnings

public void setStallWarnings(boolean stallWarnings)

Whether "stall_warnings=true" should be added to the query.

setFilterLevel

public void setFilterLevel(java.lang.String filterLevel)

One of "none", "low" or "medium"

setLanguage

public void setLanguage(java.lang.String language)

Filter tweets by language or languages.

setTrack

public void setTrack(java.lang.String track)

Filter tweets by words or phrases.

setFollow

public void setFollow(java.lang.String follow)

Restrict the stream to a user or users.

setLocations

public void setLocations(java.lang.String locations)

Bound the returned tweets by location(s).

getComponentType

public java.lang.String getComponentType()

Specified by:

getComponentType in interface org.springframework.integration.context.NamedComponent

Overrides:

getComponentType in class org.springframework.integration.context.IntegrationObjectSupport

doStart

protected void doStart()

Overrides:

doStart in class org.springframework.integration.endpoint.MessageProducerSupport

doStop

protected void doStop()

Overrides:

doStop in class org.springframework.integration.endpoint.MessageProducerSupport