org.apache.storm.mqtt.common

Class MqttUtils

java.lang.Object

org.apache.storm.mqtt.common.MqttUtils

public class MqttUtils
extends Object

Method Summary

Modifier and Type	Method and Description
static org.fusesource.mqtt.client.MQTT	configureClient(MqttOptions options, String clientId, KeyStoreLoader keyStoreLoader)
static org.fusesource.mqtt.client.QoS	qosFromInt(int i)

Methods inherited from class java.lang.Object

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

Method Detail

qosFromInt

public static org.fusesource.mqtt.client.QoS qosFromInt(int i)

configureClient

public static org.fusesource.mqtt.client.MQTT configureClient(MqttOptions options,
                                                              String clientId,
                                                              KeyStoreLoader keyStoreLoader)
                                                       throws Exception

Throws:

Exception