org.seedstack.mqtt

Class MqttConfig.ClientConfig.PoolConfig

java.lang.Object

org.seedstack.mqtt.MqttConfig.ClientConfig.PoolConfig

Enclosing class:

MqttConfig.ClientConfig

public static class MqttConfig.ClientConfig.PoolConfig
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MqttConfig.ClientConfig.PoolConfig.RejectedExecutionPolicy Supported RejectedExecutionHandler policies : ABORT: ThreadPoolExecutor.AbortPolicy is called. DISCARD: ThreadPoolExecutor.DiscardPolicy is called. CALLER_RUNS: ThreadPoolExecutor.CallerRunsPolicy is called. DISCARD_OLDEST: ThreadPoolExecutor.DiscardOldestPolicy is called.

Constructor Summary

Constructors

Constructor and Description
PoolConfig()

Method Summary

Modifier and Type	Method and Description
int	getCoreSize()
int	getKeepAlive()
int	getMaxSize()
int	getQueueSize()
MqttConfig.ClientConfig.PoolConfig.RejectedExecutionPolicy	getRejectedExecutionPolicy()
boolean	isEnabled()
MqttConfig.ClientConfig.PoolConfig	setCoreSize(int coreSize)
MqttConfig.ClientConfig.PoolConfig	setEnabled(boolean enabled)
MqttConfig.ClientConfig.PoolConfig	setKeepAlive(int keepAlive)
MqttConfig.ClientConfig.PoolConfig	setMaxSize(int maxSize)
MqttConfig.ClientConfig.PoolConfig	setQueueSize(int queueSize)
MqttConfig.ClientConfig.PoolConfig	setRejectedExecutionPolicy(MqttConfig.ClientConfig.PoolConfig.RejectedExecutionPolicy rejectedExecutionPolicy)

Methods inherited from class java.lang.Object

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

Constructor Detail

PoolConfig

public PoolConfig()

Method Detail

isEnabled

public boolean isEnabled()

setEnabled

public MqttConfig.ClientConfig.PoolConfig setEnabled(boolean enabled)

getCoreSize

public int getCoreSize()

setCoreSize

public MqttConfig.ClientConfig.PoolConfig setCoreSize(int coreSize)

getMaxSize

public int getMaxSize()

setMaxSize

public MqttConfig.ClientConfig.PoolConfig setMaxSize(int maxSize)

getQueueSize

public int getQueueSize()

setQueueSize

public MqttConfig.ClientConfig.PoolConfig setQueueSize(int queueSize)

getKeepAlive

public int getKeepAlive()

setKeepAlive

public MqttConfig.ClientConfig.PoolConfig setKeepAlive(int keepAlive)

getRejectedExecutionPolicy

public MqttConfig.ClientConfig.PoolConfig.RejectedExecutionPolicy getRejectedExecutionPolicy()

setRejectedExecutionPolicy

public MqttConfig.ClientConfig.PoolConfig setRejectedExecutionPolicy(MqttConfig.ClientConfig.PoolConfig.RejectedExecutionPolicy rejectedExecutionPolicy)