Interface | Description |
---|---|
NamedTopic<V> |
NamedTopic represents a topic entity for publish/subscribe messaging.
|
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 . |
Subscriber<V> | |
Subscriber.Element<V> |
Element represents a container for returned values.
|
Subscriber.Option<V,U> |
A marker interface to indicate that a class is a valid
Subscriber.Option
for a Subscriber . |
Class | Description |
---|---|
Publisher.FailOnFull |
The FailOnFull option indicates that the
CompletableFuture returned
from the Publisher.send(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.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.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
Function 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.
|
Enum | Description |
---|---|
Publisher.OnFailure |
This option controls how a
Publisher handles a failure of an individual
Publisher.send(V) call. |