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.NamedTopicListener A listener that receives events related to aNamedTopic
.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 theNamedTopic
.Publisher.Option<V> A marker interface to indicate that a class is a validPublisher.Option
for aPublisher
.Publisher.Orderable Orderable represents a value published byPublisher
that has a natural ordering.Publisher.Status The status for a successfully published element.Subscriber<V> 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 forSubscriber
identifiers.Subscriber.Option<V,U> A marker interface to indicate that a class is a validSubscriber.Option
for aSubscriber
.TopicDependencies The dependencies for a topic. -
Class Summary Class Description BinaryElementCalculator ANamedTopic.ElementCalculator
that calculates size of an element based on the size of the serialized binary value.FixedElementCalculator A fixed implementation of aNamedTopic.ElementCalculator
that gives all elements a size of 1.NamedTopicEvent An event related to aNamedTopic
.Publisher.FailOnFull 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.Publisher.OptionSet<V> A holder of publisher options.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 ofsent values
across all threads which share the sameorderId
.Publisher.OrderByNone<V> Publisher.OrderBy
option enforces no specific ordering betweensent 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 ofsent values
issued by a single thread will complete in order.Publisher.OrderByValue<V> Publisher.OrderBy
option which computes the unit-of-order based on applyingconstructor's
orderIdFunction parameter
onsent value
.Subscriber.Channel.EmptyChannel A default empty channel implementation.Subscriber.ChannelOwnershipListeners<V> 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.Subscriber.CommitResult The result of a commit request.Subscriber.CompleteOnEmpty<V> 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.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 NamedTopicEvent.Type Publisher.OnFailure This option controls how aPublisher
handles a failure of an individualPublisher.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 aNamedTopic
.TopicPublisherException An exception that occurred during publishing of a message on a topic.