Package energy.eddie.regionconnector.aiida.mqtt.callback

Class MqttConnectCallback

java.lang.Object
energy.eddie.regionconnector.aiida.mqtt.callback.MqttConnectCallback
All Implemented Interfaces:
org.eclipse.paho.mqttv5.client.MqttActionListener
public class MqttConnectCallback extends Object implements org.eclipse.paho.mqttv5.client.MqttActionListener

  • Constructor Summary

    Constructors
    Constructor
    Description
    MqttConnectCallback(org.eclipse.paho.mqttv5.client.MqttAsyncClient client, org.eclipse.paho.mqttv5.client.MqttConnectionOptions connectionOptions, MqttEventPublisher eventPublisher, org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler scheduler)
    Creates a new MqttConnectCallback that will retry the connection after 15s delay if the onFailure(IMqttToken, Throwable) listener is called by the client.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onFailure(org.eclipse.paho.mqttv5.client.IMqttToken asyncActionToken, Throwable exception)
     
    void
    onSuccess(org.eclipse.paho.mqttv5.client.IMqttToken asyncActionToken)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • MqttConnectCallback

      public MqttConnectCallback(org.eclipse.paho.mqttv5.client.MqttAsyncClient client, org.eclipse.paho.mqttv5.client.MqttConnectionOptions connectionOptions, MqttEventPublisher eventPublisher, org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler scheduler)
      Creates a new MqttConnectCallback that will retry the connection after 15s delay if the onFailure(IMqttToken, Throwable) listener is called by the client.

  • Method Details

    • onSuccess

      public void onSuccess(org.eclipse.paho.mqttv5.client.IMqttToken asyncActionToken)
      Specified by:
      onSuccess in interface org.eclipse.paho.mqttv5.client.MqttActionListener

    • onFailure

      public void onFailure(org.eclipse.paho.mqttv5.client.IMqttToken asyncActionToken, Throwable exception)
      Specified by:
      onFailure in interface org.eclipse.paho.mqttv5.client.MqttActionListener