org.springframework.cloud.stream.app.twitterstream.source

Class AbstractTwitterInboundChannelAdapter

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.endpoint.AbstractEndpoint

org.springframework.integration.endpoint.MessageProducerSupport

org.springframework.cloud.stream.app.twitterstream.source.AbstractTwitterInboundChannelAdapter

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.SmartInitializingSingleton, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.integration.context.ExpressionCapable, org.springframework.integration.core.MessageProducer, org.springframework.integration.support.context.NamedComponent, org.springframework.integration.support.management.TrackableComponent

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

Abstract class for the twitter inbound channel adapter.

Author:

David Turanski, Gary Russell, Artem Bilan, Christian Tzolov

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractTwitterInboundChannelAdapter.StreamReadingTask

Field Summary

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

lifecycleCondition, lifecycleLock

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

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected abstract URI	buildUri()
protected abstract void	doSendLine(String line)
protected void	doStart()
protected void	doStop()
protected void	onInit()
void	setConnectTimeout(int millis) The connection timeout for making a connection to Twitter.
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

afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack

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

destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop

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

afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, 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

getBeanName, 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.

onInit

protected void onInit()

Overrides:

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

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 URI buildUri()

doSendLine

protected abstract void doSendLine(String line)

wait

protected void wait(int millis)