static <T> QueueConsumingThreadPoolOptions.Builder<T> |
QueueConsumingThreadPoolOptions.builder() |
Builder for queue consuming thread pool options.
|
QueueConsumingThreadPoolOptions.Builder<T> |
QueueConsumingThreadPoolOptions.Builder.metricsCalculatorThreadName(java.lang.String metricsCalculatorThreadName) |
Set metrics calculator thread name.
|
QueueConsumingThreadPoolOptions.Builder<T> |
QueueConsumingThreadPoolOptions.Builder.movingAverageWaitTimeInSeconds(java.lang.Integer movingAverageWaitTimeInSeconds) |
Set moving average wait time in seconds.
|
QueueConsumingThreadPoolOptions.Builder<T> |
QueueConsumingThreadPoolOptions.Builder.numberOfProcessThreads(java.lang.Integer numberOfProcessThreads) |
Set number of process threads.
|
QueueConsumingThreadPoolOptions.Builder<T> |
QueueConsumingThreadPoolOptions.Builder.onDuplicatedItemRejectedHandler(java.util.function.BiConsumer<java.lang.Runnable,T> onDuplicatedItemRejectedHandler) |
Set on duplicated item rejected handler.
|
QueueConsumingThreadPoolOptions.Builder<T> |
QueueConsumingThreadPoolOptions.Builder.onRejectHandler(java.util.function.Consumer<java.lang.Runnable> onRejectHandler) |
Set on reject handler.
|
QueueConsumingThreadPoolOptions.Builder<T> |
QueueConsumingThreadPoolOptions.Builder.processThreadName(java.lang.String processThreadName) |
Set process thread name.
|
QueueConsumingThreadPoolOptions.Builder<T> |
QueueConsumingThreadPoolOptions.Builder.queueCapacity(java.lang.Integer queueCapacity) |
Set queue capacity.
|