io.smallrye.reactive.messaging.mqtt.session

Class MqttClientSessionOptions

java.lang.Object

io.vertx.core.net.NetworkOptions

io.vertx.core.net.TCPSSLOptions

io.vertx.core.net.ClientOptionsBase

io.vertx.core.net.NetClientOptions

io.vertx.mqtt.MqttClientOptions

io.smallrye.reactive.messaging.mqtt.session.MqttClientSessionOptions

public class MqttClientSessionOptions
extends io.vertx.mqtt.MqttClientOptions

Field Summary

Fields inherited from class io.vertx.mqtt.MqttClientOptions

DEFAULT_ACK_TIMEOUT, DEFAULT_CLEAN_SESSION, DEFAULT_HOST, DEFAULT_KEEP_ALIVE_INTERVAL, DEFAULT_MAX_INFLIGHT_QUEUE, DEFAULT_MAX_MESSAGE_SIZE, DEFAULT_PORT, DEFAULT_TSL_PORT, DEFAULT_WILL_FLAG, DEFAULT_WILL_QOS, DEFAULT_WILL_RETAIN

Fields inherited from class io.vertx.core.net.NetClientOptions

DEFAULT_HOSTNAME_VERIFICATION_ALGORITHM, DEFAULT_RECONNECT_ATTEMPTS, DEFAULT_RECONNECT_INTERVAL

Fields inherited from class io.vertx.core.net.ClientOptionsBase

DEFAULT_CONNECT_TIMEOUT, DEFAULT_METRICS_NAME, DEFAULT_TRUST_ALL

Fields inherited from class io.vertx.core.net.TCPSSLOptions

DEFAULT_ENABLED_SECURE_TRANSPORT_PROTOCOLS, DEFAULT_IDLE_TIMEOUT, DEFAULT_IDLE_TIMEOUT_TIME_UNIT, DEFAULT_SO_LINGER, DEFAULT_SSL, DEFAULT_SSL_ENGINE, DEFAULT_SSL_HANDSHAKE_TIMEOUT, DEFAULT_SSL_HANDSHAKE_TIMEOUT_TIME_UNIT, DEFAULT_TCP_CORK, DEFAULT_TCP_FAST_OPEN, DEFAULT_TCP_KEEP_ALIVE, DEFAULT_TCP_NO_DELAY, DEFAULT_TCP_QUICKACK, DEFAULT_USE_ALPN

Fields inherited from class io.vertx.core.net.NetworkOptions

DEFAULT_LOG_ENABLED, DEFAULT_RECEIVE_BUFFER_SIZE, DEFAULT_REUSE_ADDRESS, DEFAULT_REUSE_PORT, DEFAULT_SEND_BUFFER_SIZE, DEFAULT_TRAFFIC_CLASS

Constructor Summary

Constructors

Constructor and Description
MqttClientSessionOptions() Default constructor
MqttClientSessionOptions(MqttClientSessionOptions other) Copy constructor

Method Summary

Modifier and Type	Method and Description
String	getHostname()
int	getPort()
ReconnectDelayOptions	getReconnectDelay()
Optional<String>	getServerName()
MqttClientSessionOptions	setHostname(String hostname)
MqttClientSessionOptions	setPort(int port)
MqttClientSessionOptions	setReconnectDelay(ReconnectDelayOptions reconnectDelay)
MqttClientSessionOptions	setServerName(Optional<String> serverName)

Methods inherited from class io.vertx.mqtt.MqttClientOptions

addCrlPath, addCrlValue, addEnabledCipherSuite, addEnabledSecureTransportProtocol, getAckTimeout, getClientId, getKeepAliveInterval, getMaxInflightQueue, getMaxMessageSize, getPassword, getUsername, getWillMessage, getWillQoS, getWillTopic, hasPassword, hasUsername, isAutoGeneratedClientId, isAutoKeepAlive, isCleanSession, isWillFlag, isWillRetain, setAckTimeout, setAutoGeneratedClientId, setAutoKeepAlive, setCleanSession, setClientId, setIdleTimeout, setKeepAliveInterval, setKeyCertOptions, setKeyStoreOptions, setMaxInflightQueue, setMaxMessageSize, setPassword, setPemKeyCertOptions, setPemTrustOptions, setPfxKeyCertOptions, setPfxTrustOptions, setReceiveBufferSize, setSsl, setTrustAll, setTrustOptions, setTrustStoreOptions, setUsername, setWillFlag, setWillMessage, setWillQoS, setWillRetain, setWillTopic, toString

Methods inherited from class io.vertx.core.net.NetClientOptions

addNonProxyHost, getApplicationLayerProtocols, getHostnameVerificationAlgorithm, getReconnectAttempts, getReconnectInterval, removeEnabledSecureTransportProtocol, setApplicationLayerProtocols, setConnectTimeout, setEnabledSecureTransportProtocols, setHostnameVerificationAlgorithm, setIdleTimeoutUnit, setJdkSslEngineOptions, setLocalAddress, setLogActivity, setMetricsName, setNonProxyHosts, setOpenSslEngineOptions, setProxyOptions, setReconnectAttempts, setReconnectInterval, setReuseAddress, setReusePort, setSendBufferSize, setSoLinger, setSslEngineOptions, setSslHandshakeTimeout, setSslHandshakeTimeoutUnit, setTcpCork, setTcpFastOpen, setTcpKeepAlive, setTcpNoDelay, setTcpQuickAck, setTrafficClass, setUseAlpn

Methods inherited from class io.vertx.core.net.ClientOptionsBase

getConnectTimeout, getLocalAddress, getMetricsName, getNonProxyHosts, getProxyOptions, isTrustAll, toJson

Methods inherited from class io.vertx.core.net.TCPSSLOptions

getCrlPaths, getCrlValues, getEnabledCipherSuites, getEnabledSecureTransportProtocols, getIdleTimeout, getIdleTimeoutUnit, getJdkSslEngineOptions, getKeyCertOptions, getKeyStoreOptions, getOpenSslEngineOptions, getPemKeyCertOptions, getPemTrustOptions, getPfxKeyCertOptions, getPfxTrustOptions, getSoLinger, getSslEngineOptions, getSslHandshakeTimeout, getSslHandshakeTimeoutUnit, getTrustOptions, getTrustStoreOptions, isSsl, isTcpCork, isTcpFastOpen, isTcpKeepAlive, isTcpNoDelay, isTcpQuickAck, isUseAlpn

Methods inherited from class io.vertx.core.net.NetworkOptions

getLogActivity, getReceiveBufferSize, getSendBufferSize, getTrafficClass, isReuseAddress, isReusePort

Methods inherited from class java.lang.Object

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

Constructor Detail

MqttClientSessionOptions

public MqttClientSessionOptions()

Default constructor

MqttClientSessionOptions

public MqttClientSessionOptions(MqttClientSessionOptions other)

Copy constructor

Parameters:

other - the options to copy

Method Detail

getPort

public int getPort()

setPort

public MqttClientSessionOptions setPort(int port)

getHostname

public String getHostname()

setHostname

public MqttClientSessionOptions setHostname(String hostname)

setReconnectDelay

public MqttClientSessionOptions setReconnectDelay(ReconnectDelayOptions reconnectDelay)

getReconnectDelay

public ReconnectDelayOptions getReconnectDelay()

getServerName

public Optional<String> getServerName()

setServerName

public MqttClientSessionOptions setServerName(Optional<String> serverName)