Package io.smallrye.reactive.messaging.providers.connectors

Class WorkerPoolConfig

java.lang.Object

io.smallrye.reactive.messaging.providers.connectors.WorkerPoolConfig

public class WorkerPoolConfig
extends Object

Constructor Summary

Constructors

Constructor	Description
WorkerPoolConfig(int maxConcurrency, int shutdownTimeoutMs, int shutdownCheckIntervalMs)
WorkerPoolConfig(int maxConcurrency, Duration shutdownTimeout, Duration shutdownCheckInterval)

Method Summary

Modifier and Type	Method	Description
int	maxConcurrency()
Duration	shutdownCheckInterval()	The frequency at which the status of the executor service should be checked during shutdown.
Duration	shutdownTimeout()	The shutdown timeout.

Methods inherited from class java.lang.Object

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

Constructor Details

WorkerPoolConfig

public WorkerPoolConfig(int maxConcurrency,
 int shutdownTimeoutMs,
 int shutdownCheckIntervalMs)

WorkerPoolConfig

public WorkerPoolConfig(int maxConcurrency,
 Duration shutdownTimeout,
 Duration shutdownCheckInterval)

Method Details

maxConcurrency

public int maxConcurrency()

shutdownTimeout

public Duration shutdownTimeout()

The shutdown timeout. If all pending work has not been completed by this time then any pending tasks will be interrupted, and the shutdown process will continue

shutdownCheckInterval

public Duration shutdownCheckInterval()

The frequency at which the status of the executor service should be checked during shutdown.