Package | Description |
---|---|
io.vertx.mqtt | |
io.vertx.reactivex.mqtt | |
io.vertx.rxjava.mqtt | |
io.vertx.rxjava3.mqtt |
Modifier and Type | Method and Description |
---|---|
MqttServerOptions |
MqttServerOptions.addCrlPath(String crlPath) |
MqttServerOptions |
MqttServerOptions.addCrlValue(Buffer crlValue) |
MqttServerOptions |
MqttServerOptions.addEnabledCipherSuite(String suite) |
MqttServerOptions |
MqttServerOptions.addEnabledSecureTransportProtocol(String protocol) |
MqttServerOptions |
MqttServerOptions.setAutoClientId(boolean isAutoClientId)
Set if clientid should be auto-generated when it's "zero-bytes"
|
MqttServerOptions |
MqttServerOptions.setClientAuth(ClientAuth clientAuth) |
MqttServerOptions |
MqttServerOptions.setHost(String host) |
MqttServerOptions |
MqttServerOptions.setKeyCertOptions(KeyCertOptions options) |
MqttServerOptions |
MqttServerOptions.setKeyStoreOptions(JksOptions options) |
MqttServerOptions |
MqttServerOptions.setMaxClientIdLength(int maxClientIdLength)
Set the max client id length.
|
MqttServerOptions |
MqttServerOptions.setMaxMessageSize(int maxMessageSize)
Set max MQTT message size
|
MqttServerOptions |
MqttServerOptions.setPemKeyCertOptions(PemKeyCertOptions options) |
MqttServerOptions |
MqttServerOptions.setPemTrustOptions(PemTrustOptions options) |
MqttServerOptions |
MqttServerOptions.setPerFrameWebSocketCompressionSupported(boolean supported)
Enable or disable support for the WebSocket per-frame deflate compression extension.
|
MqttServerOptions |
MqttServerOptions.setPerMessageWebSocketCompressionSupported(boolean supported)
Enable or disable support for WebSocket per-message deflate compression extension.
|
MqttServerOptions |
MqttServerOptions.setPfxKeyCertOptions(PfxOptions options) |
MqttServerOptions |
MqttServerOptions.setPfxTrustOptions(PfxOptions options) |
MqttServerOptions |
MqttServerOptions.setPort(int port) |
MqttServerOptions |
MqttServerOptions.setProxyProtocolTimeout(long proxyProtocolTimeout) |
MqttServerOptions |
MqttServerOptions.setProxyProtocolTimeoutUnit(TimeUnit proxyProtocolTimeoutUnit) |
MqttServerOptions |
MqttServerOptions.setReceiveBufferSize(int receiveBufferSize) |
MqttServerOptions |
MqttServerOptions.setSni(boolean sni) |
MqttServerOptions |
MqttServerOptions.setSsl(boolean ssl) |
MqttServerOptions |
MqttServerOptions.setTimeoutOnConnect(int timeoutOnConnect)
Set the timeout on CONNECT packet
|
MqttServerOptions |
MqttServerOptions.setTrustOptions(TrustOptions options) |
MqttServerOptions |
MqttServerOptions.setTrustStoreOptions(JksOptions options) |
MqttServerOptions |
MqttServerOptions.setUseProxyProtocol(boolean useProxyProtocol) |
MqttServerOptions |
MqttServerOptions.setUseWebSocket(boolean useWebSocket)
enable mqtt over websocket
|
MqttServerOptions |
MqttServerOptions.setWebSocketAllowServerNoContext(boolean accept)
Set whether the WebSocket server will accept the
server_no_context_takeover parameter of the per-message
deflate compression extension offered by the client. |
MqttServerOptions |
MqttServerOptions.setWebSocketCompressionLevel(int compressionLevel)
Set the WebSocket compression level.
|
MqttServerOptions |
MqttServerOptions.setWebSocketPreferredClientNoContext(boolean accept)
Set whether the WebSocket server will accept the
client_no_context_takeover parameter of the per-message
deflate compression extension offered by the client. |
Modifier and Type | Method and Description |
---|---|
static MqttServer |
MqttServer.create(Vertx vertx,
MqttServerOptions options)
Return an MQTT server instance
|
Constructor and Description |
---|
MqttServerOptions(MqttServerOptions other)
Copy constructor
|
Modifier and Type | Method and Description |
---|---|
static MqttServer |
MqttServer.create(Vertx vertx,
MqttServerOptions options)
Return an MQTT server instance
|
Modifier and Type | Method and Description |
---|---|
static MqttServer |
MqttServer.create(Vertx vertx,
MqttServerOptions options)
Return an MQTT server instance
|
Modifier and Type | Method and Description |
---|---|
static MqttServer |
MqttServer.create(Vertx vertx,
MqttServerOptions options)
Return an MQTT server instance
|
Copyright © 2023 Eclipse. All rights reserved.