| 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.