Module org.yamcs.mqtt

Package org.yamcs.mqtt

Class MqttPacketLink

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.tctm.AbstractLink

org.yamcs.tctm.AbstractTcTmParamLink

org.yamcs.mqtt.MqttPacketLink

All Implemented Interfaces:

com.google.common.util.concurrent.Service, org.eclipse.paho.client.mqttv3.IMqttMessageListener, SystemParametersProducer, Link, LinkActionProvider, ParameterDataLink, TcDataLink, TmPacketDataLink

public class MqttPacketLink
extends AbstractTcTmParamLink
implements org.eclipse.paho.client.mqttv3.IMqttMessageListener

MQTT packet link - supports TM and TC packets

Nested Class Summary

Nested classes/interfaces inherited from interface org.yamcs.tctm.Link

Link.Status

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Field Summary

Fields inherited from class org.yamcs.tctm.AbstractTcTmParamLink

cmdPostProcessor, commandHistoryPublisher, packetCount, packetPreprocessor, parameterCount, parameterSink, updateSimulationTime

Fields inherited from class org.yamcs.tctm.AbstractLink

config, dataInCount, dataOutCount, disabled, eventProducer, LINK_NAMESPACE, linkName, log, timeService, yamcsInstance

Constructor Summary

Constructors

Constructor	Description
MqttPacketLink()

Method Summary

Modifier and Type	Method	Description
protected Link.Status	connectionStatus()
protected void	doDisable()
protected void	doEnable()
protected void	doStart()
protected void	doStop()
String	getDetailedStatus()
Spec	getSpec()
void	init(String yamcsInstance, String linkName, YConfiguration config)
boolean	isTcDataLinkImplemented()
boolean	isTmPacketDataLinkImplemented()
void	messageArrived(String topic, org.eclipse.paho.client.mqttv3.MqttMessage message)	Called by the MQTT client when a message is received
boolean	sendCommand(PreparedCommand preparedCommand)

Methods inherited from class org.yamcs.tctm.AbstractTcTmParamLink

ackCommand, failedCommand, getDefaultSpec, initTc, initTm, postprocess, processPacket, setCommandHistoryPublisher, setParameterSink, setTmSink

Methods inherited from class org.yamcs.tctm.AbstractLink

addAction, collectSystemParameters, dataIn, dataOut, disable, enable, getAction, getActions, getConfig, getCurrentTime, getDataInCount, getDataOutCount, getEventLoop, getLinkStatus, getName, getParent, getSystemParameters, getYamcsInstance, isDisabled, isRunningAndEnabled, resetCounters, setParent, setupSystemParameters

Methods inherited from class com.google.common.util.concurrent.AbstractService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.yamcs.tctm.Link

disable, enable, getConfig, getDataInCount, getDataOutCount, getExtraInfo, getLinkStatus, getName, getParent, isDisabled, isEffectivelyDisabled, resetCounters, setParent, setupSystemParameters

Methods inherited from interface org.yamcs.tctm.ParameterDataLink

isParameterDataLinkImplemented

Methods inherited from interface org.yamcs.parameter.SystemParametersProducer

getFrequency

Methods inherited from interface org.yamcs.tctm.TcDataLink

isCommandingAvailable

Constructor Details

MqttPacketLink

public MqttPacketLink()

Method Details

init

public void init(String yamcsInstance,
 String linkName,
 YConfiguration config)
          throws ConfigurationException

Specified by:

init in interface Link

Overrides:

init in class AbstractTcTmParamLink

Throws:

ConfigurationException

getSpec

public Spec getSpec()

Specified by:

getSpec in interface Link

sendCommand

public boolean sendCommand(PreparedCommand preparedCommand)

Specified by:

sendCommand in interface TcDataLink

messageArrived

public void messageArrived(String topic,
 org.eclipse.paho.client.mqttv3.MqttMessage message)

Called by the MQTT client when a message is received

Specified by:

messageArrived in interface org.eclipse.paho.client.mqttv3.IMqttMessageListener

doStart

protected void doStart()

Specified by:

doStart in class com.google.common.util.concurrent.AbstractService

doStop

protected void doStop()

Specified by:

doStop in class com.google.common.util.concurrent.AbstractService

getDetailedStatus

public String getDetailedStatus()

Specified by:

getDetailedStatus in interface Link

Overrides:

getDetailedStatus in class AbstractLink

doDisable

protected void doDisable()
                  throws Exception

Overrides:

doDisable in class AbstractLink

Throws:

Exception

doEnable

protected void doEnable()
                 throws Exception

Overrides:

doEnable in class AbstractLink

Throws:

Exception

connectionStatus

protected Link.Status connectionStatus()

Specified by:

connectionStatus in class AbstractLink

isTcDataLinkImplemented

public boolean isTcDataLinkImplemented()

Specified by:

isTcDataLinkImplemented in interface TcDataLink

isTmPacketDataLinkImplemented

public boolean isTmPacketDataLinkImplemented()

Specified by:

isTmPacketDataLinkImplemented in interface TmPacketDataLink