Package com.hivemq.client.mqtt.mqtt5

Interface Mqtt5Client

All Superinterfaces:

MqttClient

All Known Subinterfaces:

Mqtt5AsyncClient, Mqtt5BlockingClient, Mqtt5RxClient

@DoNotImplement
public interface Mqtt5Client
extends MqttClient

MQTT client according to the MQTT 5.0 specification.

Since:

1.0

Field Summary

Fields inherited from interface com.hivemq.client.mqtt.MqttClient

DEFAULT_SERVER_HOST, DEFAULT_SERVER_PORT, DEFAULT_SERVER_PORT_SSL, DEFAULT_SERVER_PORT_WEBSOCKET, DEFAULT_SERVER_PORT_WEBSOCKET_SSL

Method Summary

Modifier and Type	Method	Description
static @NotNull Mqtt5ClientBuilder	builder()	Creates a builder for an MQTT 5 client.
@NotNull Mqtt5ClientConfig	getConfig()
@NotNull Mqtt5AsyncClient	toAsync()	Turns the API of this client into a asynchronous API based on futures and callbacks.
@NotNull Mqtt5BlockingClient	toBlocking()	Turns the API of this client into a blocking API.
@NotNull Mqtt5RxClient	toRx()	Turns the API of this client into a reactive API.

Methods inherited from interface com.hivemq.client.mqtt.MqttClient

getState

Method Details

builder

@NotNull
static @NotNull Mqtt5ClientBuilder builder()

Creates a builder for an MQTT 5 client.

Returns:

the created builder for a MQTT 5 client.

getConfig

@NotNull
@NotNull Mqtt5ClientConfig getConfig()

Specified by:

getConfig in interface MqttClient

Returns:

the configuration of this client.

toRx

@CheckReturnValue
@NotNull
@NotNull Mqtt5RxClient toRx()

Turns the API of this client into a reactive API.

The reactive API can be used simultaneously with the other APIs.

Returns:

a reactive API for this client.

toAsync

@CheckReturnValue
@NotNull
@NotNull Mqtt5AsyncClient toAsync()

Turns the API of this client into a asynchronous API based on futures and callbacks.

The asynchronous API can be used simultaneously with the other APIs.

Returns:

a asynchronous API for this client.

toBlocking

@CheckReturnValue
@NotNull
@NotNull Mqtt5BlockingClient toBlocking()

Turns the API of this client into a blocking API.

The blocking API can be used simultaneously with the other APIs.

Returns:

a blocking API for this client.