Package lumis.portal.monitor.impl.process

Class QueueConsumingThreadPoolOptions<T>

java.lang.Object

lumis.portal.monitor.impl.process.QueueConsumingThreadPoolOptions<T>

All Implemented Interfaces:

java.lang.Cloneable

public class QueueConsumingThreadPoolOptions<T>
extends java.lang.Object
implements java.lang.Cloneable

Queue consuming thread pool options.

Since:

17.0.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	QueueConsumingThreadPoolOptions.Builder<T>	Queue consuming thread pool options builder.

Constructor Summary

Constructors

Constructor	Description
QueueConsumingThreadPoolOptions()

Method Summary

Modifier and Type	Method	Description
static <T> QueueConsumingThreadPoolOptions.Builder<T>	builder()	Builder for queue consuming thread pool options.
protected QueueConsumingThreadPoolOptions<T>	clone()
java.lang.String	getMetricsCalculatorThreadName()	Returns the metricsCalculatorThreadName.
java.lang.Integer	getMovingAverageWaitTimeInSeconds()	Returns the movingAverageWaitTimeInSeconds.
java.lang.Integer	getNumberOfProcessThreads()	Returns the numberOfProcessThreads.
java.util.function.BiConsumer<java.lang.Runnable,T>	getOnDuplicatedItemRejectedHandler()	Returns the onDuplicatedItemRejectedHandler.
java.util.function.Consumer<java.lang.Runnable>	getOnRejectHandler()	Returns the onRejectHandler.
java.lang.String	getProcessThreadName()	Returns the processThreadName.
java.lang.Integer	getQueueCapacity()	Returns the queueCapacity.

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueConsumingThreadPoolOptions

public QueueConsumingThreadPoolOptions()

Method Detail

getMovingAverageWaitTimeInSeconds

public java.lang.Integer getMovingAverageWaitTimeInSeconds()

Returns the movingAverageWaitTimeInSeconds.

Returns:

the movingAverageWaitTimeInSeconds

Since:

17.0.0

getQueueCapacity

public java.lang.Integer getQueueCapacity()

Returns the queueCapacity.

Returns:

the queueCapacity

Since:

17.0.0

getProcessThreadName

public java.lang.String getProcessThreadName()

Returns the processThreadName.

Returns:

the processThreadName

Since:

17.0.0

getNumberOfProcessThreads

public java.lang.Integer getNumberOfProcessThreads()

Returns the numberOfProcessThreads.

Returns:

the numberOfProcessThreads

Since:

17.0.0

getMetricsCalculatorThreadName

public java.lang.String getMetricsCalculatorThreadName()

Returns the metricsCalculatorThreadName.

Returns:

the metricsCalculatorThreadName

Since:

17.0.0

getOnRejectHandler

public java.util.function.Consumer<java.lang.Runnable> getOnRejectHandler()

Returns the onRejectHandler.

Returns:

the onRejectHandler

Since:

17.0.0

getOnDuplicatedItemRejectedHandler

public java.util.function.BiConsumer<java.lang.Runnable,T> getOnDuplicatedItemRejectedHandler()

Returns the onDuplicatedItemRejectedHandler.

Returns:

the onDuplicatedItemRejectedHandler

Since:

17.0.0

builder

public static <T> QueueConsumingThreadPoolOptions.Builder<T> builder()

Builder for queue consuming thread pool options.

Type Parameters:

T - the queue items identifier type

Since:

17.0.0

clone

protected QueueConsumingThreadPoolOptions<T> clone()

Overrides:

clone in class java.lang.Object