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 validPublisher.Option
for aPublisher
.Options to use with NamedTopic.createPublisher(Publisher.Option...)
Publisher Option Description Publisher.OnFailure.Stop
Default. If an individual Publisher.publish(V)
invocation fails then stop any further publishing and close thePublisher
.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 thePublisher.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 parallelismPublisher.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