Package br.com.anteros.mqtt.core.client

Class MqttClientCreator

java.lang.Object

br.com.anteros.mqtt.core.client.MqttClientCreator

public final class MqttClientCreator
extends Object

mqtt 客户端构造器

Author:

L.cm

Field Summary

Fields

Modifier and Type	Field	Description
static int	DEFAULT_KEEP_ALIVE_SECS	默认的心跳超时

Constructor Summary

Constructors

Constructor	Description
MqttClientCreator()

Method Summary

Modifier and Type	Method	Description
MqttClientCreator	bufferAllocator(br.com.anteros.mqtt.codec.ByteBufferAllocator allocator)
MqttClientCreator	cleanSession(boolean cleanSession)
MqttClientCreator	clientId(String clientId)
MqttClientCreator	clientSession(IMqttClientSession clientSession)
MqttClient	connect()
MqttClientCreator	connectListener(IMqttClientConnectListener connectListener)
br.com.anteros.mqtt.codec.ByteBufferAllocator	getBufferAllocator()
String	getClientId()
IMqttClientSession	getClientSession()
IMqttClientConnectListener	getConnectListener()
ThreadPoolExecutor	getGroupExecutor()
String	getIp()
int	getKeepAliveSecs()
int	getMaxBytesInMessage()
int	getMaxClientIdLength()
IMqttClientMessageIdGenerator	getMessageIdGenerator()
String	getName()
String	getPassword()
int	getPort()
br.com.anteros.mqtt.codec.MqttProperties	getProperties()
int	getReadBufferSize()
long	getReInterval()
int	getReSubscribeBatchSize()
int	getRetryCount()
ScheduledThreadPoolExecutor	getScheduledExecutor()
Integer	getSessionExpiryIntervalSecs()
org.tio.core.ssl.SslConfig	getSslConfig()
Integer	getTimeout()
org.tio.utils.thread.pool.SynThreadPoolExecutor	getTioExecutor()
String	getUsername()
br.com.anteros.mqtt.codec.MqttVersion	getVersion()
MqttWillMessage	getWillMessage()
MqttClientCreator	groupExecutor(ThreadPoolExecutor groupExecutor)
MqttClientCreator	ip(String ip)
boolean	isCleanSession()
boolean	isReconnect()
boolean	isStatEnable()
MqttClientCreator	keepAliveSecs(int keepAliveSecs)
MqttClientCreator	maxBytesInMessage(int maxBytesInMessage)
MqttClientCreator	maxClientIdLength(int maxClientIdLength)
MqttClientCreator	messageIdGenerator(IMqttClientMessageIdGenerator messageIdGenerator)
MqttClientCreator	name(String name)
MqttClientCreator	password(String password)
MqttClientCreator	port(int port)
MqttClientCreator	properties(br.com.anteros.mqtt.codec.MqttProperties properties)
MqttClientCreator	readBufferSize(int readBufferSize)
MqttClientCreator	reconnect(boolean reconnect)
MqttClientCreator	reInterval(long reInterval)
MqttClientCreator	reSubscribeBatchSize(int reSubscribeBatchSize)
MqttClientCreator	retryCount(int retryCount)
MqttClientCreator	scheduledExecutor(ScheduledThreadPoolExecutor scheduledExecutor)
MqttClientCreator	sessionExpiryIntervalSecs(Integer sessionExpiryIntervalSecs)
MqttClientCreator	sslConfig(org.tio.core.ssl.SslConfig sslConfig)
MqttClientCreator	statEnable()
MqttClientCreator	statEnable(boolean enable)
MqttClientCreator	timeout(int timeout)
MqttClientCreator	tioConfigCustomize(Consumer<org.tio.core.TioConfig> tioConfigCustomize)
MqttClientCreator	tioExecutor(org.tio.utils.thread.pool.SynThreadPoolExecutor tioExecutor)
MqttClientCreator	username(String username)
MqttClientCreator	version(br.com.anteros.mqtt.codec.MqttVersion version)
MqttClientCreator	willMessage(MqttWillMessage willMessage)
MqttClientCreator	willMessage(Consumer<MqttWillMessage.Builder> consumer)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_KEEP_ALIVE_SECS

public static final int DEFAULT_KEEP_ALIVE_SECS

默认的心跳超时

See Also:

Constant Field Values

Constructor Detail

MqttClientCreator

public MqttClientCreator()

Method Detail

getName

public String getName()

getIp

public String getIp()

getPort

public int getPort()

getTimeout

public Integer getTimeout()

getReadBufferSize

public int getReadBufferSize()

getMaxBytesInMessage

public int getMaxBytesInMessage()

getMaxClientIdLength

public int getMaxClientIdLength()

getKeepAliveSecs

public int getKeepAliveSecs()

getSslConfig

public org.tio.core.ssl.SslConfig getSslConfig()

isReconnect

public boolean isReconnect()

getRetryCount

public int getRetryCount()

getReInterval

public long getReInterval()

getReSubscribeBatchSize

public int getReSubscribeBatchSize()

getClientId

public String getClientId()

getVersion

public br.com.anteros.mqtt.codec.MqttVersion getVersion()

getUsername

public String getUsername()

getPassword

public String getPassword()

isCleanSession

public boolean isCleanSession()

getSessionExpiryIntervalSecs

public Integer getSessionExpiryIntervalSecs()

getWillMessage

public MqttWillMessage getWillMessage()

getProperties

public br.com.anteros.mqtt.codec.MqttProperties getProperties()

getBufferAllocator

public br.com.anteros.mqtt.codec.ByteBufferAllocator getBufferAllocator()

getConnectListener

public IMqttClientConnectListener getConnectListener()

getClientSession

public IMqttClientSession getClientSession()

getMessageIdGenerator

public IMqttClientMessageIdGenerator getMessageIdGenerator()

isStatEnable

public boolean isStatEnable()

getTioExecutor

public org.tio.utils.thread.pool.SynThreadPoolExecutor getTioExecutor()

getGroupExecutor

public ThreadPoolExecutor getGroupExecutor()

getScheduledExecutor

public ScheduledThreadPoolExecutor getScheduledExecutor()

name

public MqttClientCreator name(String name)

ip

public MqttClientCreator ip(String ip)

port

public MqttClientCreator port(int port)

timeout

public MqttClientCreator timeout(int timeout)

readBufferSize

public MqttClientCreator readBufferSize(int readBufferSize)

maxBytesInMessage

public MqttClientCreator maxBytesInMessage(int maxBytesInMessage)

maxClientIdLength

public MqttClientCreator maxClientIdLength(int maxClientIdLength)

keepAliveSecs

public MqttClientCreator keepAliveSecs(int keepAliveSecs)

sslConfig

public MqttClientCreator sslConfig(org.tio.core.ssl.SslConfig sslConfig)

reconnect

public MqttClientCreator reconnect(boolean reconnect)

retryCount

public MqttClientCreator retryCount(int retryCount)

reInterval

public MqttClientCreator reInterval(long reInterval)

reSubscribeBatchSize

public MqttClientCreator reSubscribeBatchSize(int reSubscribeBatchSize)

clientId

public MqttClientCreator clientId(String clientId)

version

public MqttClientCreator version(br.com.anteros.mqtt.codec.MqttVersion version)

username

public MqttClientCreator username(String username)

password

public MqttClientCreator password(String password)

cleanSession

public MqttClientCreator cleanSession(boolean cleanSession)

sessionExpiryIntervalSecs

public MqttClientCreator sessionExpiryIntervalSecs(Integer sessionExpiryIntervalSecs)

willMessage

public MqttClientCreator willMessage(MqttWillMessage willMessage)

willMessage

public MqttClientCreator willMessage(Consumer<MqttWillMessage.Builder> consumer)

properties

public MqttClientCreator properties(br.com.anteros.mqtt.codec.MqttProperties properties)

bufferAllocator

public MqttClientCreator bufferAllocator(br.com.anteros.mqtt.codec.ByteBufferAllocator allocator)

connectListener

public MqttClientCreator connectListener(IMqttClientConnectListener connectListener)

clientSession

public MqttClientCreator clientSession(IMqttClientSession clientSession)

messageIdGenerator

public MqttClientCreator messageIdGenerator(IMqttClientMessageIdGenerator messageIdGenerator)

statEnable

public MqttClientCreator statEnable()

statEnable

public MqttClientCreator statEnable(boolean enable)

tioExecutor

public MqttClientCreator tioExecutor(org.tio.utils.thread.pool.SynThreadPoolExecutor tioExecutor)

groupExecutor

public MqttClientCreator groupExecutor(ThreadPoolExecutor groupExecutor)

scheduledExecutor

public MqttClientCreator scheduledExecutor(ScheduledThreadPoolExecutor scheduledExecutor)

tioConfigCustomize

public MqttClientCreator tioConfigCustomize(Consumer<org.tio.core.TioConfig> tioConfigCustomize)

connect

public MqttClient connect()