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.
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.
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.