Package tweetoscope.tweetsProducer

Class TwitterFilteredStreamReaderSingleton

java.lang.Object

tweetoscope.tweetsProducer.TweetsProducer

tweetoscope.tweetsProducer.OnlineTweetsProducer

tweetoscope.tweetsProducer.TwitterFilteredStreamReaderSingleton

All Implemented Interfaces:

Runnable, Flow.Publisher<com.twitter.clientlib.model.Tweet>

public final class TwitterFilteredStreamReaderSingleton
extends OnlineTweetsProducer

Connects to the Twitter search stream endpoint and search for Tweets with given keywords (minimum 1, maximum 5). As Tweets are received, Tweet subscribers are notified. Requires the BEARER_TOKEN environment variable to be set to connect to the Twitter API endpoint. To ensure only one instance of this class is created at any time, it implements the Singleton pattern.

Author:

Virginie Galtier

Field Summary

Fields

Modifier and Type	Field	Description
protected List<String>	keywords	Keywords to search for (minimum 1, maximum 5)

Fields inherited from class tweetoscope.tweetsProducer.OnlineTweetsProducer

BEARER_TOKEN

Fields inherited from class tweetoscope.tweetsProducer.TweetsProducer

subscribers

Method Summary

Modifier and Type	Method	Description
static TwitterFilteredStreamReaderSingleton	getInstance(List<String> keywords)
void	run()

Methods inherited from class tweetoscope.tweetsProducer.TweetsProducer

subscribe

Methods inherited from class java.lang.Object

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

Field Details

keywords

protected List<String> keywords

Keywords to search for (minimum 1, maximum 5)

Method Details

getInstance

public static TwitterFilteredStreamReaderSingleton getInstance(List<String> keywords)

Returns:

single instance of the filtered Tweets producer

run

public void run()