Package com.tangosol.net.topic
package com.tangosol.net.topic
Contains classes that providing topic entities for publish/subscribe messaging.
- Since:
- 14.1.1
-
ClassDescriptionA
NamedTopic.ElementCalculator
that calculates size of an element based on the size of the serialized binary value.A fixed implementation of aNamedTopic.ElementCalculator
that gives all elements a size of 1.NamedTopic<V>NamedTopic represents a topic entity for publish/subscribe messaging.A unit calculator is an object that can calculate the cost of storing an element in a topic.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 theNamedTopic
.The FailOnFull option indicates that theCompletableFuture
returned from thePublisher.publish(V)
operation should complete exceptionally upon identifying that the topic is or has become full.This option controls how aPublisher
handles a failure of an individualPublisher.publish(V)
call.A marker interface to indicate that a class is a validPublisher.Option
for aPublisher
.Orderable represents a value published byPublisher
that has a natural ordering.The OrderBy option specifies the ordering of async operations with respect to one another.Publisher.OrderBy
option ensures ordering ofsent values
across all threads which share the sameorderId
.Publisher.OrderBy
option enforces no specific ordering betweensent values
allowing for the greatest level of parallelism.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.OrderBy
option which ensures that a sequence ofsent values
issued by a single thread will complete in order.Publisher.OrderBy
option which computes the unit-of-order based on applyingconstructor's
orderIdFunction parameter
onsent value
.The status for a successfully published element.Subscriber<V>A representation of a topic channel within subscriber.A default empty channel implementation.A listener that receives notification of channel ownership changes.A subscriberSubscriber.Option
that allows one or morelisteners
to be added to the subscriber, that will be notified of changes to the subscribers channel ownership.The result of a commit request.The different result statuses for a commit request.The CompleteOnEmpty option indicates that theCompletableFuture
returned from theSubscriber.receive()
operation should complete with a nullSubscriber.Element
upon identifying that the topic is or has become empty.Subscriber.Convert<V,U> The Convert option specifies aValueExtractor
that will convert topic values that a subscriber is interested in receiving prior to sending them to the subscriber.Element represents a container for returned values.The Filtered option specifies a filter that will determine which topic values a subscriber is interested in receiving.A marker interface forSubscriber
identifiers.The Name option is used to specify a subscriber group name.Subscriber.Option<V,U> A marker interface to indicate that a class is a validSubscriber.Option
for aSubscriber
.A base class for topic backing map managers.The dependencies for a topic.A exception that occurred during an operation on aNamedTopic
.An exception that occurred during publishing of a message on a topic.