Interface | Description |
---|---|
MqttRejectedExecutionHandler |
Rejected handler called when the thread pool blocking queue is full.
|
Class | Description |
---|---|
MqttConfig | |
MqttConfig.ClientConfig | |
MqttConfig.ClientConfig.PoolConfig |
Enum | Description |
---|---|
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.
|
MqttConfig.ClientConfig.ReconnectionMode |
Different reconnection modes when the connection is lost:
NONE: no reconnection.
ALWAYS: try to reconnect if connection is lost.
CUSTOM: Custom
MqttPublishHandler is call.
|
Annotation Type | Description |
---|---|
MqttListener |
Defined a new topic listener for a clients name.
|
MqttPublishHandler |
Defined a new publish handler for a clients name.
|
MqttRejectHandler |
Define a
RejectedExecutionHandler if thread pool queue is full. |
Copyright © 2013-2018–2019 SeedStack. All rights reserved.