public class FireAlarmMQTTCommunicator extends MQTTTransportHandler
DEFAULT_MQTT_QUALITY_OF_SERVICE, mqttBrokerEndPoint, subscribeTopic, timeoutInterval
DEFAULT_TIMEOUT_INTERVAL
Constructor and Description |
---|
FireAlarmMQTTCommunicator(String deviceOwner,
String deviceType,
String mqttBrokerEndPoint,
String subscribeTopic) |
FireAlarmMQTTCommunicator(String deviceOwner,
String deviceType,
String mqttBrokerEndPoint,
String subscribeTopic,
int intervalInMillis) |
Modifier and Type | Method and Description |
---|---|
void |
connect() |
void |
disconnect() |
ScheduledFuture<?> |
getDataPushServiceHandler() |
void |
processIncomingMessage() |
void |
processIncomingMessage(org.eclipse.paho.client.mqttv3.MqttMessage message,
String... messageParams) |
void |
publishDeviceData() |
void |
publishDeviceData(String... publishData) |
closeConnection, connectionLost, connectToQueue, deliveryComplete, isConnected, messageArrived, publishToQueue, publishToQueue, publishToQueue, setTimeoutInterval, subscribeToQueue
public FireAlarmMQTTCommunicator(String deviceOwner, String deviceType, String mqttBrokerEndPoint, String subscribeTopic)
public ScheduledFuture<?> getDataPushServiceHandler()
public void connect()
public void processIncomingMessage(org.eclipse.paho.client.mqttv3.MqttMessage message, String... messageParams)
public void publishDeviceData()
public void disconnect()
public void processIncomingMessage()
public void publishDeviceData(String... publishData)
Copyright © 2017 WSO2. All rights reserved.