Package org.openhab.core.io.transport.mqtt

Class MqttBrokerConnection.ConnectionCallback

java.lang.Object

org.openhab.core.io.transport.mqtt.MqttBrokerConnection.ConnectionCallback

All Implemented Interfaces:

com.hivemq.client.mqtt.lifecycle.MqttClientConnectedListener, com.hivemq.client.mqtt.lifecycle.MqttClientDisconnectedListener

Enclosing class:

MqttBrokerConnection

public static class MqttBrokerConnection.ConnectionCallback
extends Object
implements com.hivemq.client.mqtt.lifecycle.MqttClientConnectedListener, com.hivemq.client.mqtt.lifecycle.MqttClientDisconnectedListener

Create a listener object for being used as a callback for a connection attempt. The callback will interact with the AbstractReconnectStrategy as well as inform registered MqttConnectionObservers.

Constructor Summary

Constructors

Constructor	Description
ConnectionCallback(MqttBrokerConnection mqttBrokerConnectionImpl)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Boolean>	createFuture()
void	onConnected(@Nullable com.hivemq.client.mqtt.lifecycle.MqttClientConnectedContext context)
void	onDisconnected(@Nullable com.hivemq.client.mqtt.lifecycle.MqttClientDisconnectedContext context)
void	onDisconnected(Throwable t)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ConnectionCallback

public ConnectionCallback(MqttBrokerConnection mqttBrokerConnectionImpl)

Method Details

onConnected

public void onConnected(@Nullable com.hivemq.client.mqtt.lifecycle.MqttClientConnectedContext context)

Specified by:

onConnected in interface com.hivemq.client.mqtt.lifecycle.MqttClientConnectedListener

onDisconnected

public void onDisconnected(@Nullable com.hivemq.client.mqtt.lifecycle.MqttClientDisconnectedContext context)

Specified by:

onDisconnected in interface com.hivemq.client.mqtt.lifecycle.MqttClientDisconnectedListener

onDisconnected

public void onDisconnected(Throwable t)

createFuture

public CompletableFuture<Boolean> createFuture()