org.apache.streams.twitter.provider

Class TwitterStreamHelper

java.lang.Object

com.twitter.hbc.core.processor.AbstractProcessor<String>

com.twitter.hbc.core.processor.StringDelimitedProcessor

org.apache.streams.twitter.provider.TwitterStreamHelper

All Implemented Interfaces:

com.twitter.hbc.core.processor.HosebirdMessageProcessor

public class TwitterStreamHelper
extends com.twitter.hbc.core.processor.StringDelimitedProcessor

TwitterStreamHelper helps with hosebird twitter stream.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	TwitterStreamHelper.StreamDeserializer

Field Summary

Fields inherited from class com.twitter.hbc.core.processor.AbstractProcessor

DEFAULT_OFFER_TIMEOUT_MILLIS, offerTimeoutMillis, queue

Constructor Summary

Constructors

Constructor and Description
TwitterStreamHelper(TwitterStreamProvider provider)
TwitterStreamHelper(TwitterStreamProvider provider, int poolSize) TwitterStreamHelper constructor.

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
boolean	process()

Methods inherited from class com.twitter.hbc.core.processor.StringDelimitedProcessor

processNextMessage, setup

Methods inherited from class java.lang.Object

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

Constructor Detail

TwitterStreamHelper

public TwitterStreamHelper(TwitterStreamProvider provider)

TwitterStreamHelper

public TwitterStreamHelper(TwitterStreamProvider provider,
                           int poolSize)

TwitterStreamHelper constructor.

Parameters:

provider - TwitterStreamProvider

poolSize - poolSize

Method Detail

process

public boolean process()
                throws IOException,
                       InterruptedException

Specified by:

process in interface com.twitter.hbc.core.processor.HosebirdMessageProcessor

Overrides:

process in class com.twitter.hbc.core.processor.AbstractProcessor<String>

Throws:

IOException

InterruptedException

cleanUp

public void cleanUp()