Uses of Class
com.yahoo.bullet.pubsub.PubSubMessage

Packages that use PubSubMessage

Package	Description
com.yahoo.bullet.pubsub
com.yahoo.bullet.pubsub.rest

Uses of PubSubMessage in com.yahoo.bullet.pubsub

Fields in com.yahoo.bullet.pubsub with type parameters of type PubSubMessage

Modifier and Type	Field and Description
protected List<PubSubMessage>	BufferingSubscriber.receivedMessages A List of messages read.
protected Map<String,PubSubMessage>	BufferingSubscriber.uncommittedMessages A Map of messages that have not been committed so far.

Methods in com.yahoo.bullet.pubsub that return PubSubMessage

Modifier and Type	Method and Description
static PubSubMessage	PubSubMessage.fromJSON(String json) Converts a json representation back to an instance.
PubSubMessage	Subscriber.receive() Gets a new PubSubMessage from the assigned partition/partitions (Here a partition is a unit of parallelism in the Pub/Sub queue, See PubSub).
PubSubMessage	BufferingSubscriber.receive()
PubSubMessage	Publisher.send(PubSubMessage message) Sends a PubSubMessage.
default PubSubMessage	Publisher.send(String id, byte[] content) Send a message with an ID and content.

Methods in com.yahoo.bullet.pubsub that return types with arguments of type PubSubMessage

Modifier and Type	Method and Description
protected abstract List<PubSubMessage>	BufferingSubscriber.getMessages() Implement this method to read and return a List of PubSubMessage from your actual PubSub source.

Methods in com.yahoo.bullet.pubsub with parameters of type PubSubMessage

Modifier and Type	Method and Description
abstract void	PubSubResponder.respond(String id, PubSubMessage message) Respond to a PubSubMessage.
void	BulletPubSubResponder.respond(String id, PubSubMessage message)
PubSubMessage	Publisher.send(PubSubMessage message) Sends a PubSubMessage.

Uses of PubSubMessage in com.yahoo.bullet.pubsub.rest

Methods in com.yahoo.bullet.pubsub.rest that return PubSubMessage

Modifier and Type	Method and Description
PubSubMessage	RESTResultPublisher.send(PubSubMessage message)
PubSubMessage	RESTQueryPublisher.send(PubSubMessage message)

Methods in com.yahoo.bullet.pubsub.rest that return types with arguments of type PubSubMessage

Modifier and Type	Method and Description
List<PubSubMessage>	RESTSubscriber.getMessages()

Methods in com.yahoo.bullet.pubsub.rest with parameters of type PubSubMessage

Modifier and Type	Method and Description
PubSubMessage	RESTResultPublisher.send(PubSubMessage message)
PubSubMessage	RESTQueryPublisher.send(PubSubMessage message)
protected void	RESTPublisher.sendToURL(String url, PubSubMessage message) Send the PubSubMessage to the given url.