org.springframework.integration.x.twitter

Class AbstractTwitterInboundChannelAdapter

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.endpoint.AbstractEndpoint

org.springframework.integration.endpoint.MessageProducerSupport

org.springframework.integration.x.twitter.AbstractTwitterInboundChannelAdapter

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.core.MessageProducer, org.springframework.integration.history.TrackableComponent, org.springframework.integration.support.context.NamedComponent

Direct Known Subclasses:

TwitterSearchChannelAdapter, TwitterStreamChannelAdapter

public abstract class AbstractTwitterInboundChannelAdapter
extends org.springframework.integration.endpoint.MessageProducerSupport

Author:

David Turanski

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractTwitterInboundChannelAdapter.StreamReadingTask

Field Summary

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

logger

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractTwitterInboundChannelAdapter(org.springframework.social.twitter.api.impl.TwitterTemplate twitter)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract java.net.URI	buildUri()
protected abstract void	doSendLine(java.lang.String line)
protected void	doStart()
protected void	doStop()
java.lang.String	getLanguage()
void	setConnectTimeout(int millis) The connection timeout for making a connection to Twitter.
void	setLanguage(java.lang.String language) Filter tweets by language or languages.
void	setReadTimeout(int millis) The read timeout for the underlying URLConnection to the twitter stream.
protected void	wait(int millis)

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, getComponentType, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, 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.support.context.NamedComponent

getComponentName, getComponentType

Constructor Detail

AbstractTwitterInboundChannelAdapter

protected AbstractTwitterInboundChannelAdapter(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.

setLanguage

public void setLanguage(java.lang.String language)

Filter tweets by language or languages.

getLanguage

public java.lang.String getLanguage()

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

buildUri

protected abstract java.net.URI buildUri()

doSendLine

protected abstract void doSendLine(java.lang.String line)

wait

protected void wait(int millis)