| 限定符和类型 | 方法和说明 |
|---|---|
MqttClientCreator |
MqttClientCreator.bufferAllocator(net.dreamlu.iot.mqtt.codec.ByteBufferAllocator allocator) |
MqttClientCreator |
MqttClientCreator.cleanSession(boolean cleanSession) |
MqttClientCreator |
MqttClientCreator.clientId(String clientId) |
MqttClientCreator |
MqttClientCreator.clientSession(IMqttClientSession clientSession) |
MqttClientCreator |
MqttClientCreator.connectListener(IMqttClientConnectListener connectListener) |
static MqttClientCreator |
MqttClient.create() |
MqttClientCreator |
MqttClientCreator.debug() |
MqttClientCreator |
MqttClient.getClientCreator()
获取配置
|
MqttClientCreator |
MqttClientCreator.groupExecutor(ThreadPoolExecutor groupExecutor) |
MqttClientCreator |
MqttClientCreator.ip(String ip) |
MqttClientCreator |
MqttClientCreator.keepAliveSecs(int keepAliveSecs) |
MqttClientCreator |
MqttClientCreator.maxBytesInMessage(int maxBytesInMessage) |
MqttClientCreator |
MqttClientCreator.maxClientIdLength(int maxClientIdLength) |
MqttClientCreator |
MqttClientCreator.messageIdGenerator(IMqttClientMessageIdGenerator messageIdGenerator) |
MqttClientCreator |
MqttClientCreator.mqttExecutor(ThreadPoolExecutor mqttExecutor) |
MqttClientCreator |
MqttClientCreator.name(String name) |
MqttClientCreator |
MqttClientCreator.password(String password) |
MqttClientCreator |
MqttClientCreator.port(int port) |
MqttClientCreator |
MqttClientCreator.properties(net.dreamlu.iot.mqtt.codec.MqttProperties properties) |
MqttClientCreator |
MqttClientCreator.readBufferSize(int readBufferSize) |
MqttClientCreator |
MqttClientCreator.reconnect(boolean reconnect) |
MqttClientCreator |
MqttClientCreator.reInterval(long reInterval) |
MqttClientCreator |
MqttClientCreator.reSubscribeBatchSize(int reSubscribeBatchSize) |
MqttClientCreator |
MqttClientCreator.retryCount(int retryCount) |
MqttClientCreator |
MqttClientCreator.sessionExpiryIntervalSecs(Integer sessionExpiryIntervalSecs) |
MqttClientCreator |
MqttClientCreator.sslConfig(org.tio.core.ssl.SslConfig sslConfig) |
MqttClientCreator |
MqttClientCreator.statEnable() |
MqttClientCreator |
MqttClientCreator.statEnable(boolean enable) |
MqttClientCreator |
MqttClientCreator.taskService(org.tio.utils.timer.TimerTaskService taskService) |
MqttClientCreator |
MqttClientCreator.timeout(int timeout) |
MqttClientCreator |
MqttClientCreator.tioConfigCustomize(Consumer<org.tio.core.TioConfig> tioConfigCustomize) |
MqttClientCreator |
MqttClientCreator.tioExecutor(org.tio.utils.thread.pool.SynThreadPoolExecutor tioExecutor) |
MqttClientCreator |
MqttClientCreator.username(String username) |
MqttClientCreator |
MqttClientCreator.useSsl() |
MqttClientCreator |
MqttClientCreator.useSsl(InputStream trustStoreInputStream,
String trustPassword) |
MqttClientCreator |
MqttClientCreator.useSsl(InputStream keyStoreInputStream,
String keyPasswd,
InputStream trustStoreInputStream,
String trustPassword) |
MqttClientCreator |
MqttClientCreator.useSsl(String trustStoreFile,
String trustPassword) |
MqttClientCreator |
MqttClientCreator.useSsl(String keyStoreFile,
String keyPasswd,
String trustStoreFile,
String trustPassword) |
MqttClientCreator |
MqttClientCreator.version(net.dreamlu.iot.mqtt.codec.MqttVersion version) |
MqttClientCreator |
MqttClientCreator.willMessage(Consumer<MqttWillMessage.Builder> consumer) |
MqttClientCreator |
MqttClientCreator.willMessage(MqttWillMessage willMessage) |
| 构造器和说明 |
|---|
DefaultMqttClientProcessor(MqttClientCreator mqttClientCreator) |
MqttClientAioHandler(MqttClientCreator mqttClientCreator,
IMqttClientProcessor processor) |
MqttClientAioListener(MqttClientCreator clientCreator) |
Copyright © 2023. All rights reserved.