public class MqttServerOptions
extends io.vertx.core.net.NetServerOptions
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_MAX_MESSAGE_SIZE |
static int |
DEFAULT_PORT |
static int |
DEFAULT_TIMEOUT_ON_CONNECT |
static int |
DEFAULT_TLS_PORT |
static String |
MQTT_SUBPROTOCOL_CSV_LIST |
DEFAULT_ACCEPT_BACKLOG, DEFAULT_CLIENT_AUTH, DEFAULT_HOST, DEFAULT_PROXY_PROTOCOL_TIMEOUT, DEFAULT_PROXY_PROTOCOL_TIMEOUT_TIME_UNIT, DEFAULT_SNI, DEFAULT_USE_PROXY_PROTOCOL
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
Constructor and Description |
---|
MqttServerOptions()
Default constructor
|
MqttServerOptions(io.vertx.core.json.JsonObject json)
Create an options from JSON
|
MqttServerOptions(MqttServerOptions other)
Copy constructor
|
getAcceptBacklog, getClientAuth, getHost, getPort, isSni, removeEnabledSecureTransportProtocol, setAcceptBacklog, setEnabledSecureTransportProtocols, setIdleTimeout, setIdleTimeoutUnit, setJdkSslEngineOptions, setLogActivity, setOpenSslEngineOptions, setReuseAddress, setReusePort, setSendBufferSize, setSoLinger, setSslEngineOptions, setSslHandshakeTimeout, setSslHandshakeTimeoutUnit, setTcpCork, setTcpFastOpen, setTcpKeepAlive, setTcpNoDelay, setTcpQuickAck, setTrafficClass, setUseAlpn, toJson
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
public static final int DEFAULT_PORT
public static final int DEFAULT_TLS_PORT
public static final int DEFAULT_MAX_MESSAGE_SIZE
public static final int DEFAULT_TIMEOUT_ON_CONNECT
public static final String MQTT_SUBPROTOCOL_CSV_LIST
public MqttServerOptions()
public MqttServerOptions(io.vertx.core.json.JsonObject json)
json
- the JSONpublic MqttServerOptions(MqttServerOptions other)
other
- the options to copypublic MqttServerOptions setPort(int port)
setPort
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions setHost(String host)
setHost
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions setClientAuth(io.vertx.core.http.ClientAuth clientAuth)
setClientAuth
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions setSsl(boolean ssl)
setSsl
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions setKeyCertOptions(io.vertx.core.net.KeyCertOptions options)
setKeyCertOptions
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions setKeyStoreOptions(io.vertx.core.net.JksOptions options)
setKeyStoreOptions
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions setPfxKeyCertOptions(io.vertx.core.net.PfxOptions options)
setPfxKeyCertOptions
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions setPemKeyCertOptions(io.vertx.core.net.PemKeyCertOptions options)
setPemKeyCertOptions
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions setTrustOptions(io.vertx.core.net.TrustOptions options)
setTrustOptions
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions setTrustStoreOptions(io.vertx.core.net.JksOptions options)
setTrustStoreOptions
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions setPemTrustOptions(io.vertx.core.net.PemTrustOptions options)
setPemTrustOptions
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions setPfxTrustOptions(io.vertx.core.net.PfxOptions options)
setPfxTrustOptions
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions addEnabledCipherSuite(String suite)
addEnabledCipherSuite
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions addEnabledSecureTransportProtocol(String protocol)
addEnabledSecureTransportProtocol
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions addCrlPath(String crlPath) throws NullPointerException
addCrlPath
in class io.vertx.core.net.NetServerOptions
NullPointerException
public MqttServerOptions addCrlValue(io.vertx.core.buffer.Buffer crlValue) throws NullPointerException
addCrlValue
in class io.vertx.core.net.NetServerOptions
NullPointerException
public MqttServerOptions setReceiveBufferSize(int receiveBufferSize)
setReceiveBufferSize
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions setSni(boolean sni)
setSni
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions setMaxMessageSize(int maxMessageSize)
maxMessageSize
- max MQTT message size (variable header + payload)public int getMaxMessageSize()
public MqttServerOptions setAutoClientId(boolean isAutoClientId)
isAutoClientId
- public boolean isAutoClientId()
public MqttServerOptions setTimeoutOnConnect(int timeoutOnConnect)
timeoutOnConnect
- timeout on CONNECT before closing connectionpublic MqttServerOptions setUseProxyProtocol(boolean useProxyProtocol)
setUseProxyProtocol
in class io.vertx.core.net.NetServerOptions
public boolean isUseProxyProtocol()
isUseProxyProtocol
in class io.vertx.core.net.NetServerOptions
public long getProxyProtocolTimeout()
getProxyProtocolTimeout
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions setProxyProtocolTimeout(long proxyProtocolTimeout)
setProxyProtocolTimeout
in class io.vertx.core.net.NetServerOptions
public MqttServerOptions setProxyProtocolTimeoutUnit(TimeUnit proxyProtocolTimeoutUnit)
setProxyProtocolTimeoutUnit
in class io.vertx.core.net.NetServerOptions
public TimeUnit getProxyProtocolTimeoutUnit()
getProxyProtocolTimeoutUnit
in class io.vertx.core.net.NetServerOptions
public int timeoutOnConnect()
public MqttServerOptions setUseWebSocket(boolean useWebSocket)
useWebSocket
- use mqtt over websocketpublic boolean isUseWebSocket()
Copyright © 2021 Eclipse. All rights reserved.