Module org.yamcs.mqtt

Package org.yamcs.mqtt

Class MqttTcFrameLink

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.tctm.AbstractLink

org.yamcs.tctm.ccsds.AbstractTcFrameLink

org.yamcs.mqtt.MqttTcFrameLink

All Implemented Interfaces:

com.google.common.util.concurrent.Service, Runnable, SystemParametersProducer, AggregatedDataLink, Link, LinkActionProvider, TcDataLink

public class MqttTcFrameLink
extends AbstractTcFrameLink
implements Runnable

Sends TC as TC frames (CCSDS 232.0-B-3) or TC frames embedded in CLTU (CCSDS 231.0-B-3).

This class implements rate limiting. args:

• frameMaxRate: maximum number of command frames to send per second.

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.AbstractTcFrameLink

cltuGenerator, commandHistoryPublisher, frameCount, multiplexer

Fields inherited from class org.yamcs.tctm.AbstractLink

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

Constructor Summary

Constructors

Constructor	Description
MqttTcFrameLink()

Method Summary

Modifier and Type	Method	Description
protected Link.Status	connectionStatus()
protected void	doDisable()
protected void	doEnable()
protected void	doStart()
protected void	doStop()
Spec	getSpec()
void	init(String yamcsInstance, String name, YConfiguration config)
void	run()

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

ackBypassFrame, encodeCltu, failBypassFrame, getDefaultSpec, getSubLinks, sendCommand, setCommandHistoryPublisher

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, 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, getDetailedStatus, getExtraInfo, getLinkStatus, getName, getParent, isDisabled, isEffectivelyDisabled, resetCounters, setParent, setupSystemParameters

Methods inherited from interface org.yamcs.parameter.SystemParametersProducer

getFrequency

Methods inherited from interface org.yamcs.tctm.TcDataLink

isCommandingAvailable, isTcDataLinkImplemented

Constructor Details

MqttTcFrameLink

public MqttTcFrameLink()

Method Details

getSpec

public Spec getSpec()

Specified by:

getSpec in interface Link

init

public void init(String yamcsInstance,
 String name,
 YConfiguration config)

Specified by:

init in interface Link

Overrides:

init in class AbstractTcFrameLink

run

public void run()

Specified by:

run in interface Runnable

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

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

connectionStatus

protected Link.Status connectionStatus()

Specified by:

connectionStatus in class AbstractLink