com.tangosol.net.topic (Oracle® Coherence Java API Reference)

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.