Class PullWorkerOptions

java.lang.Object

io.superdurable.dex.PullWorkerOptions

public final class PullWorkerOptions
extends Object

Configures a Worker that opens outbound task streams to Dex.

Pass these options to WorkerOptions.Builder.pull(PullWorkerOptions). Each Worker polls its sticky queue and every registered Flow type queue. The worker does not open a listener. Zero task and idle counts and a zero timeout select defaults. An empty Worker ID is generated per Worker.

PullWorkerOptions pull = PullWorkerOptions.newBuilder()
        .maxConcurrentTasks(8)
        .stopDrainTimeout(Duration.ofSeconds(45))
        .build();
WorkerOptions options = WorkerOptions.newBuilder().pull(pull).build();

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	PullWorkerOptions.Builder	Builds immutable outbound polling options.

Method Summary

Modifier and Type	Method	Description
static PullWorkerOptions.Builder	newBuilder()	Creates a builder with CPU-count task capacity, one idle stream per queue, and a 30-second drain.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

newBuilder

public static PullWorkerOptions.Builder newBuilder()

Creates a builder with CPU-count task capacity, one idle stream per queue, and a 30-second drain.

Returns:

a mutable pull options builder