com.northconcepts.datapipeline.twitter

Class TwitterStreamProvider

java.lang.Object

com.northconcepts.datapipeline.twitter.TwitterStreamProvider

public class TwitterStreamProvider
extends Object

Streaming Twitter service provider.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	accessToken
protected String	accessTokenSecret
protected String	consumerKey
protected String	consumerSecret

Constructor Summary

Constructors

Constructor and Description
TwitterStreamProvider(String consumerKey, String consumerSecret)
TwitterStreamProvider(String consumerKey, String consumerSecret, String accessToken, String accessTokenSecret)

Method Summary

Modifier and Type	Method and Description
DataException	addExceptionProperties(DataException exception)
void	close()
ConfigurationBuilder	getConfig()
String	getHttpProxyHost()
Integer	getHttpProxyPort()
protected TwitterStream	getTwitterStream()
void	open(String rateLimitResource, String rateLimitKey)
TwitterStreamProvider	setHttpProxyHost(String httpProxyHost)
TwitterStreamProvider	setHttpProxyPort(Integer httpProxyPort)

Methods inherited from class java.lang.Object

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

Field Detail

consumerKey

protected final String consumerKey

consumerSecret

protected final String consumerSecret

accessToken

protected final String accessToken

accessTokenSecret

protected final String accessTokenSecret

Constructor Detail

TwitterStreamProvider

public TwitterStreamProvider(String consumerKey,
                             String consumerSecret)

TwitterStreamProvider

public TwitterStreamProvider(String consumerKey,
                             String consumerSecret,
                             String accessToken,
                             String accessTokenSecret)

Method Detail

getConfig

public ConfigurationBuilder getConfig()

getHttpProxyHost

public String getHttpProxyHost()

setHttpProxyHost

public TwitterStreamProvider setHttpProxyHost(String httpProxyHost)

getHttpProxyPort

public Integer getHttpProxyPort()

setHttpProxyPort

public TwitterStreamProvider setHttpProxyPort(Integer httpProxyPort)

open

public void open(String rateLimitResource,
                 String rateLimitKey)
          throws DataException

Throws:

DataException

close

public void close()
           throws DataException

Throws:

DataException

getTwitterStream

protected TwitterStream getTwitterStream()

addExceptionProperties

public DataException addExceptionProperties(DataException exception)