Package com.yahoo.bullet.pubsub

Interface Summary

Interface	Description
Publisher
Subscriber

Class Summary

Class	Description
BufferingSubscriber	This implements a Subscriber that provides a base subscriber that buffers a fixed number of messages read.
BulletPubSubResponder	Use this as a PubSubResponder if async results should be sent to a PubSub interface.
ByteArrayPubSubMessageSerDe	This SerDe is used to convert a provided Query into its serialized bytes in the PubSubMessage.
IdentityPubSubMessageSerDe
Metadata
PubSub	Notation: Partition is a unit of parallelism in the Pub/Sub queue.
PubSubMessage	The class of messages that can be understood by the PubSub package.
PubSubMessageSerDe	This allows you to hook into the PubSubMessage serialization and deserialization - for instance, if you want to customize what is done to the message before it is sent to or read in the backend.
PubSubResponder	This can be extended by any class that needs to respond to a PubSubMessage.

Enum Summary

Enum	Description
Metadata.Signal
PubSub.Context	The context determines how the Publisher and Subscriber returned by PubSub behave.

Exception Summary

Exception	Description
PubSubException	Exception to be thrown if there is an error in PubSub, Publisher or Subscriber.