org.eclipse.scada.base.extractor.mqtt.input

Class MqttInput

java.lang.Object

org.eclipse.scada.base.extractor.input.AbstractInput

org.eclipse.scada.base.extractor.mqtt.input.MqttInput

All Implemented Interfaces:

Input

public class MqttInput
extends AbstractInput

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.scada.base.extractor.input.Input

Input.Listener

Constructor Summary

Constructors

Constructor and Description
MqttInput(ScheduledExecutorService executor, String serverUri, String clientId, String topic, int qos)

Method Summary

Methods

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()

Methods inherited from class org.eclipse.scada.base.extractor.input.AbstractInput

addInputListener, addTransformer, dispose, fireData, fireDisposed, processFireData, removeInputListener, removeTransformer, setTransformers, transform

Methods inherited from class java.lang.Object

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

Constructor Detail

MqttInput

public MqttInput(ScheduledExecutorService executor,
         String serverUri,
         String clientId,
         String topic,
         int qos)

Method Detail

handleMessage

protected void handleMessage(String topic,
                 org.eclipse.paho.client.mqttv3.MqttMessage msg)

start

public void start()

stop

public void stop()

triggerConnect

protected void triggerConnect()

handleDisconnected

protected void handleDisconnected(Throwable e)

handleConnected

protected void handleConnected()

toString

public String toString()

Overrides:

toString in class Object