Package com.tangosol.net.topic

Contains classes that providing topic entities for publish/subscribe messaging.

Since:

14.1.1

Interface Summary

Interface	Description
NamedTopic<V>	NamedTopic represents a topic entity for publish/subscribe messaging.
NamedTopic.ElementCalculator	A unit calculator is an object that can calculate the cost of storing an element in a topic.
Position	An opaque representation of the position of an element within a channel of a topic.
Publisher<V>	Publisher provides a means to publish values to the NamedTopic.
Publisher.Option<V>	A marker interface to indicate that a class is a valid Publisher.Option for a Publisher.
Publisher.Orderable	Orderable represents a value published by Publisher that has a natural ordering.
Publisher.Status	The status for a successfully published element.
Subscriber<V>	A Subscriber subscribes either directly to a NamedTopic or to a subscriber group of a NamedTopic.
Subscriber.Channel	A representation of a topic channel within subscriber.
Subscriber.ChannelOwnershipListener	A listener that receives notification of channel ownership changes.
Subscriber.Element<V>	Element represents a container for returned values.
Subscriber.Id	A marker interface for Subscriber identifiers.
Subscriber.Option<V,U>	A marker interface to indicate that a class is a valid Subscriber.Option for a Subscriber.
TopicDependencies	The dependencies for a topic.

Class Summary

Class	Description
BinaryElementCalculator	A NamedTopic.ElementCalculator that calculates size of an element based on the size of the serialized binary value.
FixedElementCalculator	A fixed implementation of a NamedTopic.ElementCalculator that gives all elements a size of 1.
Publisher.FailOnFull	The FailOnFull option indicates that the CompletableFuture returned from the Publisher.publish(V) operation should complete exceptionally upon identifying that the topic is or has become full.
Publisher.OrderBy<V>	The OrderBy option specifies the ordering of async operations with respect to one another.
Publisher.OrderById<V>	Publisher.OrderBy option ensures ordering of sent values across all threads which share the same orderId.
Publisher.OrderByNone<V>	Publisher.OrderBy option enforces no specific ordering between sent values allowing for the greatest level of parallelism.
Publisher.OrderByRoundRobin<V>	Publisher.OrderBy option which computes the unit-of-order such that each message is sent to the next channel in a round-robin order.
Publisher.OrderByThread<V>	Publisher.OrderBy option which ensures that a sequence of sent values issued by a single thread will complete in order.
Publisher.OrderByValue<V>	Publisher.OrderBy option which computes the unit-of-order based on applying constructor's orderIdFunction parameter on sent value.
Subscriber.Channel.EmptyChannel	A default empty channel implementation.
Subscriber.ChannelOwnershipListeners<V>	A subscriber Subscriber.Option that allows one or more listeners to be added to the subscriber, that will be notified of changes to the subscribers channel ownership.
Subscriber.CommitResult	The result of a commit request.
Subscriber.CompleteOnEmpty<V>	The CompleteOnEmpty option indicates that the CompletableFuture returned from the Subscriber.receive() operation should complete with a null Subscriber.Element upon identifying that the topic is or has become empty.
Subscriber.Convert<V,U>	The Convert option specifies a ValueExtractor that will convert topic values that a subscriber is interested in receiving prior to sending them to the subscriber.
Subscriber.Filtered<V>	The Filtered option specifies a filter that will determine which topic values a subscriber is interested in receiving.
Subscriber.Name<V>	The Name option is used to specify a subscriber group name.
TopicBackingMapManager<D extends TopicDependencies,S extends NamedTopicScheme>	A base class for topic backing map managers.

Enum Summary

Enum	Description
Publisher.OnFailure	This option controls how a Publisher handles a failure of an individual Publisher.publish(V) call.
Subscriber.CommitResultStatus	The different result statuses for a commit request.

Exception Summary

Exception	Description
TopicException	A exception that occurred during an operation on a NamedTopic.
TopicPublisherException	An exception that occurred during publishing of a message on a topic.