Package br.com.anteros.mqtt.core.server

Class MqttServerCreator

java.lang.Object

br.com.anteros.mqtt.core.server.MqttServerCreator

public class MqttServerCreator
extends Object

mqtt 服务端参数构造

Author:

L.cm

Constructor Summary

Constructors

Constructor	Description
MqttServerCreator()

Method Summary

Modifier and Type	Method	Description
MqttServerCreator	authHandler(IMqttServerAuthHandler authHandler)
MqttServerCreator	bufferAllocator(br.com.anteros.mqtt.codec.ByteBufferAllocator bufferAllocator)
MqttServer	build()
MqttServerCreator	connectStatusListener(IMqttConnectStatusListener connectStatusListener)
MqttServerCreator	debug()
IMqttServerAuthHandler	getAuthHandler()
br.com.anteros.mqtt.codec.ByteBufferAllocator	getBufferAllocator()
IMqttConnectStatusListener	getConnectStatusListener()
Long	getHeartbeatTimeout()
String	getHttpBasicPassword()
String	getHttpBasicUsername()
String	getIp()
org.tio.core.stat.IpStatListener	getIpStatListener()
float	getKeepaliveBackoff()
int	getMaxBytesInMessage()
int	getMaxClientIdLength()
IMqttMessageDispatcher	getMessageDispatcher()
IMqttMessageListener	getMessageListener()
IMqttMessageStore	getMessageStore()
String	getName()
String	getNodeName()
int	getPort()
IMqttServerPublishPermission	getPublishPermission()
int	getReadBufferSize()
IMqttSessionManager	getSessionManager()
org.tio.core.ssl.SslConfig	getSslConfig()
IMqttServerSubscribeValidator	getSubscribeValidator()
IMqttServerUniqueIdService	getUniqueIdService()
int	getWebPort()
MqttServerCreator	heartbeatTimeout(Long heartbeatTimeout)
MqttServerCreator	httpBasicAuth(String username, String password)
MqttServerCreator	httpEnable(boolean httpEnable)
MqttServerCreator	ip(String ip)
MqttServerCreator	ipStatListener(org.tio.core.stat.IpStatListener ipStatListener)
boolean	isDebug()
boolean	isHttpEnable()
boolean	isStatEnable()
boolean	isUseQueueDecode()
boolean	isUseQueueSend()
boolean	isWebsocketEnable()
MqttServerCreator	keepaliveBackoff(float keepaliveBackoff)
MqttServerCreator	maxBytesInMessage(int maxBytesInMessage)
MqttServerCreator	maxClientIdLength(int maxClientIdLength)
MqttServerCreator	messageDispatcher(IMqttMessageDispatcher messageDispatcher)
MqttServerCreator	messageListener(IMqttMessageListener messageListener)
MqttServerCreator	messageStore(IMqttMessageStore messageStore)
MqttServerCreator	name(String name)
MqttServerCreator	nodeName(String nodeName)
MqttServerCreator	port(int port)
MqttServerCreator	publishPermission(IMqttServerPublishPermission publishPermission)
MqttServerCreator	readBufferSize(int readBufferSize)
MqttServerCreator	sessionManager(IMqttSessionManager sessionManager)
MqttServer	start()
MqttServerCreator	statEnable()
MqttServerCreator	statEnable(boolean enable)
MqttServerCreator	subscribeValidator(IMqttServerSubscribeValidator subscribeValidator)
MqttServerCreator	tioConfigCustomize(Consumer<org.tio.core.TioConfig> tioConfigCustomize)
MqttServerCreator	uniqueIdService(IMqttServerUniqueIdService uniqueIdService)
MqttServerCreator	useQueueDecode(boolean useQueueDecode)
MqttServerCreator	useQueueSend(boolean useQueueSend)
MqttServerCreator	useSsl(InputStream keyStoreInputStream, InputStream trustStoreInputStream, String pwd)
MqttServerCreator	useSsl(String keyStoreFile, String trustStoreFile, String pwd)
MqttServerCreator	webPort(int webPort)
MqttServerCreator	websocketEnable(boolean websocketEnable)

Methods inherited from class java.lang.Object

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

Constructor Detail

MqttServerCreator

public MqttServerCreator()

Method Detail

getName

public String getName()

name

public MqttServerCreator name(String name)

getIp

public String getIp()

ip

public MqttServerCreator ip(String ip)

getPort

public int getPort()

port

public MqttServerCreator port(int port)

getHeartbeatTimeout

public Long getHeartbeatTimeout()

heartbeatTimeout

public MqttServerCreator heartbeatTimeout(Long heartbeatTimeout)

getKeepaliveBackoff

public float getKeepaliveBackoff()

keepaliveBackoff

public MqttServerCreator keepaliveBackoff(float keepaliveBackoff)

getReadBufferSize

public int getReadBufferSize()

readBufferSize

public MqttServerCreator readBufferSize(int readBufferSize)

getMaxBytesInMessage

public int getMaxBytesInMessage()

maxBytesInMessage

public MqttServerCreator maxBytesInMessage(int maxBytesInMessage)

getBufferAllocator

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

bufferAllocator

public MqttServerCreator bufferAllocator(br.com.anteros.mqtt.codec.ByteBufferAllocator bufferAllocator)

getSslConfig

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

useSsl

public MqttServerCreator useSsl(InputStream keyStoreInputStream,
                                InputStream trustStoreInputStream,
                                String pwd)

useSsl

public MqttServerCreator useSsl(String keyStoreFile,
                                String trustStoreFile,
                                String pwd)

getIpStatListener

public org.tio.core.stat.IpStatListener getIpStatListener()

ipStatListener

public MqttServerCreator ipStatListener(org.tio.core.stat.IpStatListener ipStatListener)

getAuthHandler

public IMqttServerAuthHandler getAuthHandler()

authHandler

public MqttServerCreator authHandler(IMqttServerAuthHandler authHandler)

getUniqueIdService

public IMqttServerUniqueIdService getUniqueIdService()

uniqueIdService

public MqttServerCreator uniqueIdService(IMqttServerUniqueIdService uniqueIdService)

getSubscribeValidator

public IMqttServerSubscribeValidator getSubscribeValidator()

subscribeValidator

public MqttServerCreator subscribeValidator(IMqttServerSubscribeValidator subscribeValidator)

getPublishPermission

public IMqttServerPublishPermission getPublishPermission()

publishPermission

public MqttServerCreator publishPermission(IMqttServerPublishPermission publishPermission)

getMessageDispatcher

public IMqttMessageDispatcher getMessageDispatcher()

messageDispatcher

public MqttServerCreator messageDispatcher(IMqttMessageDispatcher messageDispatcher)

getMessageStore

public IMqttMessageStore getMessageStore()

messageStore

public MqttServerCreator messageStore(IMqttMessageStore messageStore)

getSessionManager

public IMqttSessionManager getSessionManager()

sessionManager

public MqttServerCreator sessionManager(IMqttSessionManager sessionManager)

getMessageListener

public IMqttMessageListener getMessageListener()

messageListener

public MqttServerCreator messageListener(IMqttMessageListener messageListener)

getConnectStatusListener

public IMqttConnectStatusListener getConnectStatusListener()

connectStatusListener

public MqttServerCreator connectStatusListener(IMqttConnectStatusListener connectStatusListener)

isDebug

public boolean isDebug()

debug

public MqttServerCreator debug()

getMaxClientIdLength

public int getMaxClientIdLength()

maxClientIdLength

public MqttServerCreator maxClientIdLength(int maxClientIdLength)

getWebPort

public int getWebPort()

webPort

public MqttServerCreator webPort(int webPort)

isWebsocketEnable

public boolean isWebsocketEnable()

websocketEnable

public MqttServerCreator websocketEnable(boolean websocketEnable)

isHttpEnable

public boolean isHttpEnable()

httpEnable

public MqttServerCreator httpEnable(boolean httpEnable)

getHttpBasicUsername

public String getHttpBasicUsername()

httpBasicAuth

public MqttServerCreator httpBasicAuth(String username,
                                       String password)

getHttpBasicPassword

public String getHttpBasicPassword()

getNodeName

public String getNodeName()

nodeName

public MqttServerCreator nodeName(String nodeName)

isUseQueueSend

public boolean isUseQueueSend()

useQueueSend

public MqttServerCreator useQueueSend(boolean useQueueSend)

isUseQueueDecode

public boolean isUseQueueDecode()

useQueueDecode

public MqttServerCreator useQueueDecode(boolean useQueueDecode)

isStatEnable

public boolean isStatEnable()

statEnable

public MqttServerCreator statEnable()

statEnable

public MqttServerCreator statEnable(boolean enable)

tioConfigCustomize

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

build

public MqttServer build()

start

public MqttServer start()