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.StatusNested 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, updateSimulationTimeFields inherited from class org.yamcs.tctm.AbstractLink
config, dataInCount, dataOutCount, disabled, eventProducer, LINK_NAMESPACE, linkName, log, timeService, yamcsInstance -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected Link.Statusprotected voidprotected voiddoEnable()protected voiddoStart()protected voiddoStop()getSpec()voidinit(String yamcsInstance, String linkName, YConfiguration config) booleanbooleanvoidmessageArrived(String topic, org.eclipse.paho.client.mqttv3.MqttMessage message) Called by the MQTT client when a message is receivedbooleansendCommand(PreparedCommand preparedCommand) Methods inherited from class org.yamcs.tctm.AbstractTcTmParamLink
ackCommand, failedCommand, getDefaultSpec, initTc, initTm, postprocess, processPacket, setCommandHistoryPublisher, setParameterSink, setTmSinkMethods 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, setupSystemParametersMethods 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, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.yamcs.tctm.Link
disable, enable, getConfig, getDataInCount, getDataOutCount, getExtraInfo, getLinkStatus, getName, getParent, isDisabled, isEffectivelyDisabled, resetCounters, setParent, setupSystemParametersMethods inherited from interface org.yamcs.tctm.ParameterDataLink
isParameterDataLinkImplementedMethods inherited from interface org.yamcs.parameter.SystemParametersProducer
getFrequencyMethods 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:
initin interfaceLink- Overrides:
initin classAbstractTcTmParamLink- Throws:
ConfigurationException
-
getSpec
-
sendCommand
- Specified by:
sendCommandin interfaceTcDataLink
-
messageArrived
Called by the MQTT client when a message is received- Specified by:
messageArrivedin interfaceorg.eclipse.paho.client.mqttv3.IMqttMessageListener
-
doStart
protected void doStart()- Specified by:
doStartin classcom.google.common.util.concurrent.AbstractService
-
doStop
protected void doStop()- Specified by:
doStopin classcom.google.common.util.concurrent.AbstractService
-
getDetailedStatus
- Specified by:
getDetailedStatusin interfaceLink- Overrides:
getDetailedStatusin classAbstractLink
-
doDisable
- Overrides:
doDisablein classAbstractLink- Throws:
Exception
-
doEnable
- Overrides:
doEnablein classAbstractLink- Throws:
Exception
-
connectionStatus
- Specified by:
connectionStatusin classAbstractLink
-
isTcDataLinkImplemented
public boolean isTcDataLinkImplemented()- Specified by:
isTcDataLinkImplementedin interfaceTcDataLink
-
isTmPacketDataLinkImplemented
public boolean isTmPacketDataLinkImplemented()- Specified by:
isTmPacketDataLinkImplementedin interfaceTmPacketDataLink
-