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.ElementCalculatorthat calculates size of an element based on the size of the serialized binary value.A fixed implementation of aNamedTopic.ElementCalculatorthat 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 theCompletableFuturereturned from thePublisher.publish(V)operation should complete exceptionally upon identifying that the topic is or has become full.This option controls how aPublisherhandles a failure of an individualPublisher.publish(V)call.A marker interface to indicate that a class is a validPublisher.Optionfor aPublisher.Orderable represents a value published byPublisherthat has a natural ordering.The OrderBy option specifies the ordering of async operations with respect to one another.Publisher.OrderByoption ensures ordering ofsent valuesacross all threads which share the sameorderId.Publisher.OrderByoption enforces no specific ordering betweensent valuesallowing for the greatest level of parallelism.Publisher.OrderByoption which computes the unit-of-order such that each message is sent to the next channel in a round-robin order.Publisher.OrderByoption which ensures that a sequence ofsent valuesissued by a single thread will complete in order.Publisher.OrderByoption which computes the unit-of-order based on applyingconstructor'sorderIdFunction parameteronsent 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.Optionthat allows one or morelistenersto 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 theCompletableFuturereturned from theSubscriber.receive()operation should complete with a nullSubscriber.Elementupon identifying that the topic is or has become empty.Subscriber.Convert<V,U> The Convert option specifies aValueExtractorthat 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 forSubscriberidentifiers.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.Optionfor 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.