Package com.tangosol.net.topic
Interface Publisher.Option<V>
- All Known Implementing Classes:
Publisher.FailOnFull
,Publisher.OnFailure
,Publisher.OrderBy
,Publisher.OrderById
,Publisher.OrderByNone
,Publisher.OrderByRoundRobin
,Publisher.OrderByThread
,Publisher.OrderByValue
public static interface Publisher.Option<V>
A marker interface to indicate that a class is a valid
Publisher.Option
for a Publisher
.
Publisher Option | Description |
Publisher.OnFailure.Stop |
Default. If an individual Publisher.publish(V) invocation fails then stop any further publishing and close the Publisher . |
Publisher.OnFailure.Continue |
If an individual Publisher.publish(V) invocation fails then skip that value and continue to publish other values. |
FailOnFull.enabled() |
When the storage size of the unprocessed values on the topic exceed a configured high-units,
the CompletableFuture returned from the Publisher.publish(V) invocation should complete exceptionally.
Overrides the default to block completing until the operation completes when space becomes available. |
Publisher.OrderBy.thread() |
Default. Ensure that all values sent from
the same thread are stored sequentially. |
Publisher.OrderBy.none() |
Enforce no specific ordering between sent values allowing
for the greatest level of parallelism |
Publisher.OrderBy.id(int) |
Ensure ordering of sent values across
all threads which share the same id. |
Publisher.OrderBy.value(ToIntFunction) |
Compute the unit-of-order based on the applying this method on sent value |
Publisher.OrderBy.value(Remote.ToIntFunction) |
Compute the unit-of-order based on the applying this method on sent value |