com.yahoo.bullet.pubsub.rest

Class RESTPubSub

java.lang.Object

com.yahoo.bullet.pubsub.PubSub

com.yahoo.bullet.pubsub.rest.RESTPubSub

public class RESTPubSub
extends PubSub

Nested Class Summary

Nested classes/interfaces inherited from class com.yahoo.bullet.pubsub.PubSub

PubSub.Context

Field Summary

Fields

Modifier and Type	Field and Description
static int	NO_CONTENT_204
static int	OK_200
static String	UTF_8

Fields inherited from class com.yahoo.bullet.pubsub.PubSub

config, context

Constructor Summary

Constructors

Constructor and Description
RESTPubSub(BulletConfig config) Create a RESTPubSub from a BulletConfig.

Method Summary

Modifier and Type	Method and Description
Publisher	getPublisher() Get a Publisher instance wired to write to all allocated partitions in the appropriate queue (See PubSub.context).
List<Publisher>	getPublishers(int n) Get a list of n Publisher instances with the allocated partitions in the appropriate queue (See PubSub.context) split as evenly as possible among them.
Subscriber	getSubscriber() Get a Subscriber instance wired to read from all allocated partitions in the appropriate queue (See PubSub.context).
List<Subscriber>	getSubscribers(int n) Get a list of n Subscriber instances with allocated partitions from the appropriate queue (See PubSub.context) split as evenly as possible among them.

Methods inherited from class com.yahoo.bullet.pubsub.PubSub

from, getRequiredConfig, switchContext

Methods inherited from class java.lang.Object

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

Field Detail

OK_200

public static final int OK_200

See Also:

Constant Field Values

NO_CONTENT_204

public static final int NO_CONTENT_204

See Also:

Constant Field Values

UTF_8

public static final String UTF_8

See Also:

Constant Field Values

Constructor Detail

RESTPubSub

public RESTPubSub(BulletConfig config)
           throws PubSubException

Create a RESTPubSub from a BulletConfig.

Parameters:

config - The config.

Throws:

PubSubException - if the context name is not present or cannot be parsed.

Method Detail

getPublisher

public Publisher getPublisher()

Description copied from class: PubSub

Get a Publisher instance wired to write to all allocated partitions in the appropriate queue (See PubSub.context).

Specified by:

getPublisher in class PubSub

Returns:

Publisher wired as required.

getPublishers

public List<Publisher> getPublishers(int n)

Description copied from class: PubSub

Get a list of n Publisher instances with the allocated partitions in the appropriate queue (See PubSub.context) split as evenly as possible among them.

Specified by:

getPublishers in class PubSub

Parameters:

n - The number of Publishers requested.

Returns:

The List of n Publishers wired as required.

getSubscriber

public Subscriber getSubscriber()

Description copied from class: PubSub

Get a Subscriber instance wired to read from all allocated partitions in the appropriate queue (See PubSub.context).

Specified by:

getSubscriber in class PubSub

Returns:

Subscriber wired as required.

getSubscribers

public List<Subscriber> getSubscribers(int n)

Description copied from class: PubSub

Get a list of n Subscriber instances with allocated partitions from the appropriate queue (See PubSub.context) split as evenly as possible among them.

Specified by:

getSubscribers in class PubSub

Parameters:

n - The number of Subscribers requested.

Returns:

The List of n Subscribers wired as required.