server/io.spine.server.delivery/DeliveryBuilder

DeliveryBuilder

public final class DeliveryBuilder

A builder for Delivery instances.

Functions

Link copied to clipboard
public Delivery build()
Link copied to clipboard
public Optional<Integer> catchUpPageSize()
Returns the value of the configured catch-up page size or Optional.empty() if no such value was configured.
Link copied to clipboard
public Optional<CatchUpStorage> catchUpStorage()
Returns the value of the configured CatchUpStorage or Optional.empty() if no such value was configured.
Link copied to clipboard
public Optional<Duration> deduplicationWindow()
Returns the value of the configured deduplication window or Optional.empty() if no such value was configured.
Link copied to clipboard
public Optional<DeliveryMonitor> deliveryMonitor()
Returns the value of the configured DeliveryMonitor or Optional.empty() if no such value was configured.
Link copied to clipboard
public Optional<InboxStorage> inboxStorage()
Returns the value of the configured InboxStorage or Optional.empty() if no such value was configured.
Link copied to clipboard
public Optional<Integer> pageSize()
Returns the value of the configured page size or Optional.empty() if no such value was configured.
Link copied to clipboard
public DeliveryBuilder setCatchUpPageSize(int catchUpPageSize)
Sets the maximum number of events to read from an event store per single read operation during the catch-up.
Link copied to clipboard
public DeliveryBuilder setCatchUpStorage(CatchUpStorage catchUpStorage)
Sets the custom CatchUpStorage.
Link copied to clipboard
public DeliveryBuilder setDeduplicationWindow(Duration deduplicationWindow)
Sets for how long the previously delivered messages should be kept in the Inbox to ensure the incoming messages aren't duplicates.
Link copied to clipboard
public DeliveryBuilder setInboxStorage(InboxStorage inboxStorage)
Sets the custom InboxStorage.
Link copied to clipboard
public DeliveryBuilder setMonitor(DeliveryMonitor monitor)
Sets the custom DeliveryMonitor.
Link copied to clipboard
public DeliveryBuilder setPageSize(int pageSize)
Sets the maximum amount of messages to deliver within a DeliveryStage.
Link copied to clipboard
public DeliveryBuilder setStrategy(DeliveryStrategy strategy)
Sets strategy of assigning a shard index for a message that is delivered to a particular target.
Link copied to clipboard
Link copied to clipboard
public Optional<DeliveryStrategy> strategy()
Returns the value of the configured DeliveryStrategy or Optional.empty() if no such value was configured.
Link copied to clipboard
public Optional<ShardedWorkRegistry> workRegistry()
Returns the value of the configured ShardedWorkRegistry or Optional.empty() if no such value was configured.