Module org.yamcs.mqtt

Package org.yamcs.mqtt

Class MqttTmFrameLink

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.tctm.AbstractLink

org.yamcs.tctm.ccsds.AbstractTmFrameLink

org.yamcs.mqtt.MqttTmFrameLink

All Implemented Interfaces:

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

public class MqttTmFrameLink
extends AbstractTmFrameLink
implements org.eclipse.paho.client.mqttv3.IMqttMessageListener

Receives telemetry fames via MQTT. One MQTT message = one TM frame.

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.ccsds.AbstractTmFrameLink

errFrameCount, frameHandler, invalidFrameCount, rawFrameDecoder, subLinks, validFrameCount

Fields inherited from class org.yamcs.tctm.AbstractLink

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

Constructor Summary

Constructors

Constructor	Description
MqttTmFrameLink()

Method Summary

Modifier and Type	Method	Description
protected Link.Status	connectionStatus()
protected void	doDisable()
protected void	doEnable()
protected void	doStart()
protected void	doStop()
Map<String,Object>	getExtraInfo()
Spec	getSpec()
void	init(String instance, String name, YConfiguration config)	Creates a new UDP Frame Data Link
void	messageArrived(String topic, org.eclipse.paho.client.mqttv3.MqttMessage message)	Called by the MQTT client when a message is received

Methods inherited from class org.yamcs.tctm.ccsds.AbstractTmFrameLink

getDefaultSpec, getSubLinks, handleFrame, resetCounters

Methods inherited from class org.yamcs.tctm.AbstractLink

addAction, collectSystemParameters, dataIn, dataOut, disable, enable, getAction, getActions, getConfig, getCurrentTime, getDataInCount, getDataOutCount, getDetailedStatus, getEventLoop, getLinkStatus, getName, getParent, getSystemParameters, getYamcsInstance, isDisabled, isRunningAndEnabled, 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, getDetailedStatus, getLinkStatus, getName, getParent, isDisabled, isEffectivelyDisabled, setParent, setupSystemParameters

Methods inherited from interface org.yamcs.parameter.SystemParametersProducer

getFrequency

Constructor Details

MqttTmFrameLink

public MqttTmFrameLink()

Method Details

getSpec

public Spec getSpec()

Specified by:

getSpec in interface Link

init

public void init(String instance,
 String name,
 YConfiguration config)
          throws ConfigurationException

Creates a new UDP Frame Data Link

Specified by:

init in interface Link

Overrides:

init in class AbstractTmFrameLink

Throws:

ConfigurationException - if port is not defined in the configuration

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

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

getExtraInfo

public Map<String,Object> getExtraInfo()

Specified by:

getExtraInfo in interface Link

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