Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withAckTimeoutSeconds(Long ackTimeoutSeconds) |
Sets the time interval to wait for an ack after sending a QoS 1+ PUBLISH, SUBSCRIBE, or UNSUBSCRIBE before
failing the operation.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withBootstrap(ClientBootstrap bootstrap) |
Sets the ClientBootstrap to use.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withConnackTimeoutMs(Long connackTimeoutMs) |
Sets the time interval to wait after sending a CONNECT request for a CONNACK to arrive.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withConnectOptions(ConnectPacket connectOptions) |
Sets all configurable options with respect to the CONNECT packet sent by the client, including the Will.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withExtendedValidationAndFlowControlOptions(Mqtt5ClientOptions.ExtendedValidationAndFlowControlOptions extendedValidationAndFlowControlOptions) |
Sets the additional controls for client behavior with respect to operation validation and flow control; these checks
go beyond the base MQTT5 spec to respect limits of specific MQTT brokers.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withHostName(String hostName) |
Sets the host name of the MQTT server to connect to.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withHttpProxyOptions(HttpProxyOptions httpProxyOptions) |
Sets the (tunneling) HTTP proxy usage when establishing MQTT connection.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withLifecycleEvents(Mqtt5ClientOptions.LifecycleEvents lifecycleEvents) |
Sets the Lifecycle Events interface that will be called when the client gets a LifecycleEvent.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withMaxReconnectDelayMs(Long maxReconnectDelayMs) |
Sets the maximum amount of time to wait to reconnect after a disconnect.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withMinConnectedTimeToResetReconnectDelayMs(Long minConnectedTimeToResetReconnectDelayMs) |
Sets the minimum time needed to pass to reset the reconnect delay in milliseconds used when the Mqtt5Client connects.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withMinReconnectDelayMs(Long minReconnectDelayMs) |
Sets the minimum amount of time to wait to reconnect after a disconnect.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withOfflineQueueBehavior(Mqtt5ClientOptions.ClientOfflineQueueBehavior offlineQueueBehavior) |
Sets how disconnects affect the queued and in-progress operations tracked by the client.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withPingTimeoutMs(Long pingTimeoutMs) |
Sets the time interval to wait after sending a PINGREQ for a PINGRESP to arrive.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withPort(Long port) |
Sets the network port of the MQTT server to connect to.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withPublishEvents(Mqtt5ClientOptions.PublishEvents publishEvents) |
Sets the PublishEvents interface that will be called when the client gets a message.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withRetryJitterMode(ExponentialBackoffRetryOptions.JitterMode retryJitterMode) |
Sets how the reconnect delay is modified in order to smooth out the distribution of reconnection attempt
time points for a large set of reconnecting clients.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withSessionBehavior(Mqtt5ClientOptions.ClientSessionBehavior sessionBehavior) |
Sets how the Mqtt5Client should behave with respect to MQTT sessions.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withSocketOptions(SocketOptions socketOptions) |
Sets the socket properties of the underlying MQTT connections made by the client.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withTlsContext(TlsContext tlsContext) |
Sets the TLS context for secure socket connections.
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withTopicAliasingOptions(TopicAliasingOptions options) |
Sets the topic aliasing options for clients constructed from this builder
|
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder |
Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder.withWebsocketHandshakeTransform(Consumer<Mqtt5WebsocketHandshakeTransformArgs> handshakeTransform) |
Sets the callback that allows a custom transformation of the HTTP request that acts as the websocket handshake.
|