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.
static PubSubMessage	PubSubMessage.fromJSON(String json, com.google.gson.Gson gson) Converts a JSON representation back to an instance using a specific Gson converter.
PubSubMessage	IdentityPubSubMessageSerDe.fromMessage(PubSubMessage message)
abstract PubSubMessage	PubSubMessageSerDe.fromMessage(PubSubMessage message) Takes a converted PubSubMessage and returns the original format of the message.
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, Serializable content) Send a message with an ID and content.
PubSubMessage	IdentityPubSubMessageSerDe.toMessage(PubSubMessage message)
abstract PubSubMessage	PubSubMessageSerDe.toMessage(PubSubMessage message) Takes a PubSubMessage and returns the new format of the message.
PubSubMessage	ByteArrayPubSubMessageSerDe.toMessage(String id, Query query, String queryString)
PubSubMessage	PubSubMessageSerDe.toMessage(String id, Query query, String queryString) A helper to submit a query by converting it to a standard PubSubMessage and running it through PubSubMessageSerDe.toMessage(PubSubMessage).

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
PubSubMessage	IdentityPubSubMessageSerDe.fromMessage(PubSubMessage message)
abstract PubSubMessage	PubSubMessageSerDe.fromMessage(PubSubMessage message) Takes a converted PubSubMessage and returns the original format of the message.
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.
PubSubMessage	IdentityPubSubMessageSerDe.toMessage(PubSubMessage message)
abstract PubSubMessage	PubSubMessageSerDe.toMessage(PubSubMessage message) Takes a PubSubMessage and returns the new format of the message.

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.