public class MqttInput extends AbstractInput
Input.Listener
Constructor and Description |
---|
MqttInput(ScheduledExecutorService executor,
String serverUri,
String clientId,
String topic,
int qos) |
Modifier and Type | Method and Description |
---|---|
protected void |
handleConnected() |
protected void |
handleDisconnected(Throwable e) |
protected void |
handleMessage(String topic,
org.eclipse.paho.client.mqttv3.MqttMessage msg) |
void |
start() |
void |
stop() |
String |
toString() |
protected void |
triggerConnect() |
addInputListener, addTransformer, dispose, fireData, fireDisposed, processFireData, removeInputListener, removeTransformer, setTransformers, transform
public MqttInput(ScheduledExecutorService executor, String serverUri, String clientId, String topic, int qos)
protected void handleMessage(String topic, org.eclipse.paho.client.mqttv3.MqttMessage msg)
public void start()
public void stop()
protected void triggerConnect()
protected void handleDisconnected(Throwable e)
protected void handleConnected()
Copyright © 2016 Eclipse NeoSCADA Project. All rights reserved.