Package com.hivemq.client.mqtt.mqtt5

Interface Mqtt5RxClient

All Superinterfaces:

Mqtt5Client, MqttClient

@DoNotImplement
public interface Mqtt5RxClient
extends Mqtt5Client

Reactive API of an Mqtt5Client.

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
@NotNull Single<Mqtt5ConnAck>	connect()	Creates a Single for connecting this client with the default Connect message.
@NotNull Single<Mqtt5ConnAck>	connect(@NotNull Mqtt5Connect connect)	Creates a Single for connecting this client with the given Connect message.
@NotNull Mqtt5ConnectBuilder.Nested<Single<Mqtt5ConnAck>>	connectWith()	Fluent counterpart of connect(Mqtt5Connect).
@NotNull Completable	disconnect()	Creates a Completable for disconnecting this client with the default Disconnect message.
@NotNull Completable	disconnect(@NotNull Mqtt5Disconnect disconnect)	Creates a Completable for disconnecting this client with the given Disconnect message.
@NotNull Mqtt5DisconnectBuilder.Nested<Completable>	disconnectWith()	Fluent counterpart of disconnect(Mqtt5Disconnect).
@NotNull Flowable<Mqtt5PublishResult>	publish(@NotNull Flowable<Mqtt5Publish> publishFlowable)	Creates a Flowable for publishing the Publish messages emitted by the given Flowable.
@NotNull Flowable<Mqtt5Publish>	publishes(@NotNull MqttGlobalPublishFilter filter)	Creates a Flowable for globally consuming all incoming Publish messages matching the given filter.
@NotNull Flowable<Mqtt5Publish>	publishes(@NotNull MqttGlobalPublishFilter filter, boolean manualAcknowledgement)	Creates a Flowable for globally consuming all incoming Publish messages matching the given filter.
@NotNull Completable	reauth()	Creates a Completable for re-authenticating this client.
@NotNull Single<Mqtt5SubAck>	subscribe(@NotNull Mqtt5Subscribe subscribe)	Creates a Single for subscribing this client with the given Subscribe message.
@NotNull FlowableWithSingle<Mqtt5Publish,Mqtt5SubAck>	subscribePublishes(@NotNull Mqtt5Subscribe subscribe)	Creates a FlowableWithSingle for subscribing this client with the given Subscribe message.
@NotNull FlowableWithSingle<Mqtt5Publish,Mqtt5SubAck>	subscribePublishes(@NotNull Mqtt5Subscribe subscribe, boolean manualAcknowledgement)	Creates a FlowableWithSingle for subscribing this client with the given Subscribe message.
@NotNull Mqtt5SubscribeBuilder.Publishes.Start<FlowableWithSingle<Mqtt5Publish,Mqtt5SubAck>>	subscribePublishesWith()	Fluent counterpart of subscribePublishes(Mqtt5Subscribe, boolean).
@NotNull FlowableWithSingle<Mqtt5Publish,Mqtt5SubAck>	subscribeStream(@NotNull Mqtt5Subscribe subscribe)	Deprecated. use subscribePublishes(Mqtt5Subscribe).
@NotNull Mqtt5SubscribeBuilder.Nested.Start<FlowableWithSingle<Mqtt5Publish,Mqtt5SubAck>>	subscribeStreamWith()	Deprecated. use subscribePublishesWith().
@NotNull Mqtt5SubscribeBuilder.Nested.Start<Single<Mqtt5SubAck>>	subscribeWith()	Fluent counterpart of subscribe(Mqtt5Subscribe).
default @NotNull Mqtt5RxClient	toRx()	Turns the API of this client into a reactive API.
@NotNull Single<Mqtt5UnsubAck>	unsubscribe(@NotNull Mqtt5Unsubscribe unsubscribe)	Creates a Single for unsubscribing this client with the given Unsubscribe message.
@NotNull Mqtt5UnsubscribeBuilder.Nested.Start<Single<Mqtt5UnsubAck>>	unsubscribeWith()	Fluent counterpart of unsubscribe(Mqtt5Unsubscribe).

Methods inherited from interface com.hivemq.client.mqtt.mqtt5.Mqtt5Client

getConfig, toAsync, toBlocking

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

getState

Method Details

connect

@CheckReturnValue
@NotNull
@NotNull Single<Mqtt5ConnAck> connect()

Creates a Single for connecting this client with the default Connect message.

Returns:

see connect(Mqtt5Connect).

See Also:

• connect(Mqtt5Connect)

connect

@CheckReturnValue
@NotNull
@NotNull Single<Mqtt5ConnAck> connect(@NotNull
 @NotNull Mqtt5Connect connect)

Creates a Single for connecting this client with the given Connect message.

The returned Single represents the source of the ConnAck message corresponding to the given Connect message. Calling this method does not connect yet. Connecting is performed lazy and asynchronous when subscribing (in terms of Reactive Streams) to the returned Single.

Parameters:

connect - the Connect message sent to the broker during connect.

Returns:

the Single which

• succeeds with the ConnAck message if it does not contain an Error Code (connected successfully),
• errors with a Mqtt5ConnAckException wrapping the ConnAck message if it contains an Error Code or
• errors with a different exception if an error occurred before the Connect message was sent or before the ConnAck message was received.

connectWith

@CheckReturnValue
@NotNull Mqtt5ConnectBuilder.Nested<Single<Mqtt5ConnAck>> connectWith()

Fluent counterpart of connect(Mqtt5Connect).

Calling Mqtt5ConnectBuilder.Nested.applyConnect() on the returned builder has the same effect as calling connect(Mqtt5Connect) with the result of Mqtt5ConnectBuilder.build().

Returns:

the fluent builder for the Connect message.

See Also:

• connect(Mqtt5Connect)

subscribe

@CheckReturnValue
@NotNull
@NotNull Single<Mqtt5SubAck> subscribe(@NotNull
 @NotNull Mqtt5Subscribe subscribe)

Creates a Single for subscribing this client with the given Subscribe message.

The returned Single represents the source of the SubAck message corresponding to the given Subscribe message. Calling this method does not subscribe yet. Subscribing is performed lazy and asynchronous when subscribing (in terms of Reactive Streams) to the returned Single.

See publishes(MqttGlobalPublishFilter) to consume the incoming Publish messages. Alternatively, call subscribePublishes(Mqtt5Subscribe) to consume the incoming Publish messages matching the subscriptions of the Subscribe message directly.

Parameters:

subscribe - the Subscribe message sent to the broker during subscribe.

Returns:

the Single which

• succeeds with the SubAck message if at least one subscription of the Subscribe message was successful (the SubAck message contains at least one Reason Code that is not an Error Code),
• errors with a Mqtt5SubAckException wrapping the SubAck message if it only contains Error Codes or
• errors with a different exception if an error occurred before the Subscribe message was sent or before a SubAck message was received.

subscribeWith

@CheckReturnValue
@NotNull Mqtt5SubscribeBuilder.Nested.Start<Single<Mqtt5SubAck>> subscribeWith()

Fluent counterpart of subscribe(Mqtt5Subscribe).

Calling Mqtt5SubscribeBuilder.Nested.Complete.applySubscribe() on the returned builder has the same effect as calling subscribe(Mqtt5Subscribe) with the result of Mqtt5SubscribeBuilder.Complete.build().

Returns:

the fluent builder for the Subscribe message.

See Also:

• subscribe(Mqtt5Subscribe)

subscribeStream

@Deprecated
@NotNull
@NotNull FlowableWithSingle<Mqtt5Publish,Mqtt5SubAck> subscribeStream(@NotNull
 @NotNull Mqtt5Subscribe subscribe)

Deprecated.

use subscribePublishes(Mqtt5Subscribe).

Use subscribePublishes(Mqtt5Subscribe).

Parameters:

subscribe - use subscribePublishes(Mqtt5Subscribe).

Returns:

use subscribePublishes(Mqtt5Subscribe).

subscribeStreamWith

@Deprecated
@NotNull Mqtt5SubscribeBuilder.Nested.Start<FlowableWithSingle<Mqtt5Publish,Mqtt5SubAck>> subscribeStreamWith()

Deprecated.

use subscribePublishesWith().

Use subscribePublishesWith().

Returns:

use subscribePublishesWith().

subscribePublishes

@CheckReturnValue
@NotNull
@NotNull FlowableWithSingle<Mqtt5Publish,Mqtt5SubAck> subscribePublishes(@NotNull
 @NotNull Mqtt5Subscribe subscribe)

Creates a FlowableWithSingle for subscribing this client with the given Subscribe message.

The returned FlowableWithSingle represents the source of the SubAck message corresponding to the given Subscribe message and the source of the incoming Publish messages matching the subscriptions of the Subscribe message. Calling this method does not subscribe yet. Subscribing is performed lazy and asynchronous when subscribing (in terms of Reactive Streams) to the returned FlowableWithSingle.

Parameters:

subscribe - the Subscribe message sent to the broker during subscribe.

Returns:

the FlowableWithSingle which

• emits the SubAck message as the single and first element if at least one subscription of the Subscribe message was successful (the SubAck message contains at least one Reason Code that is not an Error Code) and then emits the Publish messages matching the successful subscriptions of the Subscribe message,
• completes when all subscriptions of the Subscribe message were unsubscribed,
• errors with a Mqtt5SubAckException wrapping the SubAck message if it only contains Error Codes or
• errors with a different exception if an error occurred before the Subscribe message was sent, before a SubAck message was received or when a error occurs before all subscriptions of the Subscribe message were unsubscribed (e.g. MqttSessionExpiredException).

Since:

1.2

See Also:

• subscribePublishes(Mqtt5Subscribe, boolean)

subscribePublishes

@CheckReturnValue
@NotNull
@NotNull FlowableWithSingle<Mqtt5Publish,Mqtt5SubAck> subscribePublishes(@NotNull
 @NotNull Mqtt5Subscribe subscribe,
 boolean manualAcknowledgement)

Creates a FlowableWithSingle for subscribing this client with the given Subscribe message.

The returned FlowableWithSingle represents the source of the SubAck message corresponding to the given Subscribe message and the source of the incoming Publish messages matching the subscriptions of the Subscribe message. Calling this method does not subscribe yet. Subscribing is performed lazy and asynchronous when subscribing (in terms of Reactive Streams) to the returned FlowableWithSingle.

Parameters:

subscribe - the Subscribe message sent to the broker during subscribe.

manualAcknowledgement - whether the Publish messages are acknowledged manually.

Returns:

the FlowableWithSingle which

• emits the SubAck message as the single and first element if at least one subscription of the Subscribe message was successful (the SubAck message contains at least one Reason Code that is not an Error Code) and then emits the Publish messages matching the successful subscriptions of the Subscribe message,
• completes when all subscriptions of the Subscribe message were unsubscribed,
• errors with a Mqtt5SubAckException wrapping the SubAck message if it only contains Error Codes or
• errors with a different exception if an error occurred before the Subscribe message was sent, before a SubAck message was received or when a error occurs before all subscriptions of the Subscribe message were unsubscribed (e.g. MqttSessionExpiredException).

Since:

1.2

See Also:

• subscribePublishes(Mqtt5Subscribe)

subscribePublishesWith

@CheckReturnValue
@NotNull Mqtt5SubscribeBuilder.Publishes.Start<FlowableWithSingle<Mqtt5Publish,Mqtt5SubAck>> subscribePublishesWith()

Fluent counterpart of subscribePublishes(Mqtt5Subscribe, boolean).

Calling Mqtt5SubscribeBuilder.Nested.Complete.applySubscribe() on the returned builder has the same effect as calling subscribePublishes(Mqtt5Subscribe) with the result of Mqtt5SubscribeBuilder.Complete.build().

Returns:

the fluent builder for the Subscribe message.

Since:

1.2

See Also:

• subscribePublishes(Mqtt5Subscribe, boolean)

publishes

@CheckReturnValue
@NotNull
@NotNull Flowable<Mqtt5Publish> publishes(@NotNull
 @NotNull MqttGlobalPublishFilter filter)

Creates a Flowable for globally consuming all incoming Publish messages matching the given filter.

The returned Flowable represents the source of the incoming Publish messages matching the given type. Calling this method does not start consuming yet. This is done lazy and asynchronous when subscribing (in terms of Reactive Streams) to the returned Flowable.

Parameters:

filter - the filter with which all incoming Publish messages are filtered.

Returns:

the Flowable which

• emits the incoming Publish messages matching the given filter,
• never completes but
• errors with a MqttSessionExpiredException when the MQTT session expires.

See Also:

• publishes(MqttGlobalPublishFilter, boolean)

publishes

@CheckReturnValue
@NotNull
@NotNull Flowable<Mqtt5Publish> publishes(@NotNull
 @NotNull MqttGlobalPublishFilter filter,
 boolean manualAcknowledgement)

Creates a Flowable for globally consuming all incoming Publish messages matching the given filter.

The returned Flowable represents the source of the incoming Publish messages matching the given type. Calling this method does not start consuming yet. This is done lazy and asynchronous when subscribing (in terms of Reactive Streams) to the returned Flowable.

Parameters:

filter - the filter with which all incoming Publish messages are filtered.

manualAcknowledgement - whether the Publish messages are acknowledged manually.

Returns:

the Flowable which

• emits the incoming Publish messages matching the given filter,
• never completes but
• errors with a MqttSessionExpiredException when the MQTT session expires.

Since:

1.2

See Also:

• publishes(MqttGlobalPublishFilter)

unsubscribe

@CheckReturnValue
@NotNull
@NotNull Single<Mqtt5UnsubAck> unsubscribe(@NotNull
 @NotNull Mqtt5Unsubscribe unsubscribe)

Creates a Single for unsubscribing this client with the given Unsubscribe message.

The returned Single represents the source of the UnsubAck message corresponding to the given Unsubscribe message. Calling this method does not unsubscribe yet. Unsubscribing is performed lazy and asynchronous when subscribing (in terms of Reactive Streams) to the returned Single.

Parameters:

unsubscribe - the Unsubscribe message sent to the broker during unsubscribe.

Returns:

the Single which

• succeeds with the UnsubAck message if at least one Topic Filter of the Unsubscribe message was successfully unsubscribed (the UnsubAck message contains at least one Reason Code that is not an Error Code),
• errors with a Mqtt5UnsubAckException wrapping the UnsubAck message if it only contains Error Codes or
• errors with a different exception if an error occurred before the Unsubscribe message was sent or before a UnsubAck message was received.

unsubscribeWith

@CheckReturnValue
@NotNull Mqtt5UnsubscribeBuilder.Nested.Start<Single<Mqtt5UnsubAck>> unsubscribeWith()

Fluent counterpart of unsubscribe(Mqtt5Unsubscribe).

Calling Mqtt5UnsubscribeBuilder.Nested.Complete.applyUnsubscribe() on the returned builder has the same effect as calling unsubscribe(Mqtt5Unsubscribe) with the result of Mqtt5UnsubscribeBuilder.Complete.build().

Returns:

the fluent builder for the Unsubscribe message.

See Also:

• unsubscribe(Mqtt5Unsubscribe)

publish

@CheckReturnValue
@NotNull
@NotNull Flowable<Mqtt5PublishResult> publish(@NotNull
 @NotNull Flowable<Mqtt5Publish> publishFlowable)

Creates a Flowable for publishing the Publish messages emitted by the given Flowable.

The returned Flowable represents the source of Mqtt5PublishResults each corresponding to a Publish message emitted by the given Flowable. Calling this method does not start publishing yet. Publishing is performed lazy and asynchronous. When subscribing (in terms of Reactive Streams) to the returned Flowable the client subscribes (in terms of Reactive Streams) to the given Flowable.

Parameters:

publishFlowable - the source of the Publish messages to publish.

Returns:

the Flowable which

• emits Mqtt5PublishResults each corresponding to a Publish message,
• completes if the given Flowable completes, but not before all Mqtt5PublishResults were emitted, or
• errors with the same exception if the given Flowable errors, but not before all Mqtt5PublishResults were emitted.

reauth

@CheckReturnValue
@NotNull
@NotNull Completable reauth()

Creates a Completable for re-authenticating this client.

Calling this method does not re-authenticate yet. Re-authenticating is performed lazy and asynchronous when subscribing (in terms of Reactive Streams) to the returned Completable.

Returns:

the Completable which

• completes when the client was successfully re-authenticated,
• errors with a Mqtt5AuthException wrapping the Auth message with the Error Code if not re-authenticated successfully or
• errors with a different exception if an error occurred before the first Auth message was sent or before the last Auth message was received.

disconnect

@CheckReturnValue
@NotNull
@NotNull Completable disconnect()

Creates a Completable for disconnecting this client with the default Disconnect message.

Returns:

see disconnect(Mqtt5Disconnect).

See Also:

• disconnect(Mqtt5Disconnect)

disconnect

@CheckReturnValue
@NotNull
@NotNull Completable disconnect(@NotNull
 @NotNull Mqtt5Disconnect disconnect)

Creates a Completable for disconnecting this client with the given Disconnect message.

Calling this method does not disconnect yet. Disconnecting is performed lazy and asynchronous when subscribing (in terms of Reactive Streams) to the returned Completable.

Parameters:

disconnect - the Disconnect message sent to the broker during disconnect.

Returns:

the Completable which

• completes when the client was successfully disconnected or
• errors if not disconnected gracefully.

disconnectWith

@CheckReturnValue
@NotNull Mqtt5DisconnectBuilder.Nested<Completable> disconnectWith()

Fluent counterpart of disconnect(Mqtt5Disconnect).

Calling Mqtt5DisconnectBuilder.Nested.applyDisconnect() on the returned builder has the same effect as calling disconnect(Mqtt5Disconnect) with the result of Mqtt5DisconnectBuilder.build().

Returns:

the builder for the Disconnect message.

See Also:

• disconnect(Mqtt5Disconnect)

toRx

@CheckReturnValue
@NotNull
default @NotNull Mqtt5RxClient toRx()

Description copied from interface: Mqtt5Client

Turns the API of this client into a reactive API.

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

Specified by:

toRx in interface Mqtt5Client

Returns:

a reactive API for this client.