Package | Description |
---|---|
com.tangosol.net.topic |
Modifier and Type | Class and Description |
---|---|
static class |
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. |
static class |
Publisher.OnFailure
This option controls how a
Publisher handles a failure of an individual
Publisher.send(V) call. |
static class |
Publisher.OrderBy<V>
The OrderBy option specifies the ordering of async operations with respect
to one another.
|
static class |
Publisher.OrderById<V>
Publisher.OrderBy option ensures ordering of sent values across
all threads which share the same orderId . |
static class |
Publisher.OrderByNone<V>
Publisher.OrderBy option enforces no specific ordering between sent values allowing
for the greatest level of parallelism. |
static class |
Publisher.OrderByThread<V>
Publisher.OrderBy option which ensures that a sequence of sent values issued by a single thread will
complete in order. |
static class |
Publisher.OrderByValue<V>
Publisher.OrderBy option which computes the unit-of-order based on applying
constructor's orderIdFunction parameter on sent value . |
Modifier and Type | Method and Description |
---|---|
Publisher<V> |
NamedTopic.createPublisher(Publisher.Option<? super V>... options)
Create a
Publisher that can publish values into this NamedTopic . |