Class PollerOptions

java.lang.Object

io.temporal.internal.worker.PollerOptions

public final class PollerOptions
extends Object

Options for component that polls Temporal task queues for tasks.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	PollerOptions.Builder

Field Summary

Fields

Modifier and Type	Field	Description
static final String	UNHANDLED_COMMAND_EXCEPTION_MESSAGE

Method Summary

Modifier and Type	Method	Description
double	getBackoffCoefficient()
Duration	getBackoffCongestionInitialInterval()
Duration	getBackoffInitialInterval()
Duration	getBackoffMaximumInterval()
double	getBackoffMaximumJitterCoefficient()
static PollerOptions	getDefaultInstance()
int	getMaximumPollRateIntervalMilliseconds()
double	getMaximumPollRatePerSecond()
PollerBehavior	getPollerBehavior()
ExecutorService	getPollerTaskExecutorOverride()
String	getPollThreadNamePrefix()
Thread.UncaughtExceptionHandler	getUncaughtExceptionHandler()
boolean	isUsingVirtualThreads()
static PollerOptions.Builder	newBuilder()
static PollerOptions.Builder	newBuilder(PollerOptions options)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

UNHANDLED_COMMAND_EXCEPTION_MESSAGE

public static final String UNHANDLED_COMMAND_EXCEPTION_MESSAGE

See Also:

• Constant Field Values

Method Details

newBuilder

public static PollerOptions.Builder newBuilder()

newBuilder

public static PollerOptions.Builder newBuilder(PollerOptions options)

getDefaultInstance

public static PollerOptions getDefaultInstance()

getMaximumPollRateIntervalMilliseconds

public int getMaximumPollRateIntervalMilliseconds()

getMaximumPollRatePerSecond

public double getMaximumPollRatePerSecond()

getBackoffCoefficient

public double getBackoffCoefficient()

getBackoffInitialInterval

public Duration getBackoffInitialInterval()

getBackoffCongestionInitialInterval

public Duration getBackoffCongestionInitialInterval()

getBackoffMaximumInterval

public Duration getBackoffMaximumInterval()

getBackoffMaximumJitterCoefficient

public double getBackoffMaximumJitterCoefficient()

getPollerBehavior

public PollerBehavior getPollerBehavior()

getUncaughtExceptionHandler

public Thread.UncaughtExceptionHandler getUncaughtExceptionHandler()

getPollThreadNamePrefix

public String getPollThreadNamePrefix()

isUsingVirtualThreads

public boolean isUsingVirtualThreads()

getPollerTaskExecutorOverride

public ExecutorService getPollerTaskExecutorOverride()

toString

public String toString()

Overrides:

toString in class Object