Interface Publisher.Option<V>

All Known Implementing Classes:
Publisher.FailOnFull, Publisher.OnFailure, Publisher.OrderBy, Publisher.OrderById, Publisher.OrderByNone, Publisher.OrderByRoundRobin, Publisher.OrderByThread, Publisher.OrderByValue
Enclosing interface:
Publisher<V>

public static interface Publisher.Option<V>
A marker interface to indicate that a class is a valid Publisher.Option for a Publisher.

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 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