Module org.yamcs.mqtt

Package org.yamcs.mqtt

Class MqttUtils

java.lang.Object

org.yamcs.mqtt.MqttUtils

public class MqttUtils
extends Object

A set of utilities used by the MQTT packet and frame links to avoid code duplication

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	MqttUtils.NotifyFailedCallback
static interface	MqttUtils.NotifyStoppedCallback
static interface	MqttUtils.SubscriptionFailureCallback

Constructor Summary

Constructors

Constructor	Description
MqttUtils()

Method Summary

Modifier and Type	Method	Description
static void	doDisable(org.eclipse.paho.client.mqttv3.MqttAsyncClient client)
static void	doStop(org.eclipse.paho.client.mqttv3.MqttAsyncClient client, MqttUtils.NotifyStoppedCallback stopCb, MqttUtils.NotifyFailedCallback failCb)

Methods inherited from class java.lang.Object

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

Constructor Details

MqttUtils

public MqttUtils()

Method Details

doDisable

public static void doDisable(org.eclipse.paho.client.mqttv3.MqttAsyncClient client)
                      throws org.eclipse.paho.client.mqttv3.MqttException

Throws:

org.eclipse.paho.client.mqttv3.MqttException

doStop

public static void doStop(org.eclipse.paho.client.mqttv3.MqttAsyncClient client,
 MqttUtils.NotifyStoppedCallback stopCb,
 MqttUtils.NotifyFailedCallback failCb)