Package tweetoscope.tweetsProducer

Class MockTwitterStreamRandom

java.lang.Object

tweetoscope.tweetsProducer.TweetsProducer

tweetoscope.tweetsProducer.OfflineTweetsProducer

tweetoscope.tweetsProducer.MockTwitterStreamRandom

All Implemented Interfaces:

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

public final class MockTwitterStreamRandom
extends OfflineTweetsProducer

Mimics the TwitterStreamSampleReaderSingleton class. To be used when the Twitter sampled stream rate limit is exceeded for instance. Creates a continuous stream of random Tweets.

Author:

Virginie Galtier

Field Summary

Fields inherited from class tweetoscope.tweetsProducer.TweetsProducer

subscribers

Constructor Summary

Constructors

Constructor	Description
MockTwitterStreamRandom()	Creates a new MockTwitterStreamRandom.

Method Summary

Modifier and Type	Method	Description
void	run()	Posts random Tweets to the invalid reference distributed_tweetoscope.TweetoscopeAppConfig#TWEETS_TOPIC_NAME Kafka topic.

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

Constructor Details

MockTwitterStreamRandom

public MockTwitterStreamRandom()

Creates a new MockTwitterStreamRandom.

Method Details

run

public void run()

Posts random Tweets to the

invalid reference

distributed_tweetoscope.TweetoscopeAppConfig#TWEETS_TOPIC_NAME

Kafka topic. A random Tweet text is a concatenation of hashtags chosen from a reduced set. The Tweet is also assigned a language among a reduced list.