com.hashmapinc.kubeless

Class MqttUtility

java.lang.Object

com.hashmapinc.kubeless.MqttUtility

public class MqttUtility
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	MQTT_TOPIC

Constructor Summary

Constructors

Constructor and Description
MqttUtility()
MqttUtility(String mqttUrl, String accessToken)

Method Summary

Modifier and Type	Method and Description
org.eclipse.paho.client.mqttv3.MqttAsyncClient	connect()
void	disconnect(org.eclipse.paho.client.mqttv3.MqttAsyncClient client)
String	getAccessToken()
String	getMqttUrl()
void	publish(org.eclipse.paho.client.mqttv3.MqttAsyncClient client, String data, Long ts, String deviceName)
void	publish(org.eclipse.paho.client.mqttv3.MqttAsyncClient client, String data, String deviceName)
void	setAccessToken(String accessToken)
void	setMqttUrl(String mqttUrl)

Methods inherited from class java.lang.Object

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

Field Detail

MQTT_TOPIC

public static final String MQTT_TOPIC

See Also:

Constant Field Values

Constructor Detail

MqttUtility

public MqttUtility()

MqttUtility

public MqttUtility(String mqttUrl,
                   String accessToken)

Method Detail

getMqttUrl

public String getMqttUrl()

setMqttUrl

public void setMqttUrl(String mqttUrl)

getAccessToken

public String getAccessToken()

setAccessToken

public void setAccessToken(String accessToken)

connect

public org.eclipse.paho.client.mqttv3.MqttAsyncClient connect()
                                                       throws org.eclipse.paho.client.mqttv3.MqttException

Throws:

org.eclipse.paho.client.mqttv3.MqttException

publish

public void publish(org.eclipse.paho.client.mqttv3.MqttAsyncClient client,
                    String data,
                    String deviceName)
             throws org.eclipse.paho.client.mqttv3.MqttException,
                    com.fasterxml.jackson.core.JsonProcessingException

Throws:

org.eclipse.paho.client.mqttv3.MqttException

com.fasterxml.jackson.core.JsonProcessingException

publish

public void publish(org.eclipse.paho.client.mqttv3.MqttAsyncClient client,
                    String data,
                    Long ts,
                    String deviceName)
             throws org.eclipse.paho.client.mqttv3.MqttException,
                    com.fasterxml.jackson.core.JsonProcessingException

Throws:

org.eclipse.paho.client.mqttv3.MqttException

com.fasterxml.jackson.core.JsonProcessingException

disconnect

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

Throws:

org.eclipse.paho.client.mqttv3.MqttException