com.yahoo.bullet.rest.common

Class Reader

java.lang.Object

com.yahoo.bullet.rest.common.Reader

public class Reader
extends Object

Constructor Summary

Constructors

Constructor and Description
Reader(com.yahoo.bullet.pubsub.Subscriber subscriber, com.yahoo.bullet.pubsub.PubSubResponder responder, int sleepTimeMS) Create a service with a Subscriber and a request queue.

Method Summary

Modifier and Type	Method and Description
void	close() Interrupt the reader thread and close the Subscriber.
void	run() Read responses from the PubSub and update requests.
void	start() Starts reading from the pubsub.

Methods inherited from class java.lang.Object

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

Constructor Detail

Reader

public Reader(com.yahoo.bullet.pubsub.Subscriber subscriber,
              com.yahoo.bullet.pubsub.PubSubResponder responder,
              int sleepTimeMS)

Create a service with a Subscriber and a request queue.

Parameters:

subscriber - The Subscriber to read responses from.

responder - The PubSubResponder to use to respond.

sleepTimeMS - The duration to sleep for if PubSub receive is empty. Helps prevent busy waiting.

Method Detail

start

public void start()

Starts reading from the pubsub.

close

public void close()

Interrupt the reader thread and close the Subscriber.

run

public void run()

Read responses from the PubSub and update requests.