org.yamcs.tctm

Class ArtemisTmDataLink

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.tctm.ArtemisTmDataLink

All Implemented Interfaces:

com.google.common.util.concurrent.Service, org.apache.activemq.artemis.api.core.client.MessageHandler, Link, TmPacketDataLink

public class ArtemisTmDataLink
extends com.google.common.util.concurrent.AbstractService
implements TmPacketDataLink, org.apache.activemq.artemis.api.core.client.MessageHandler

receives data from Artemis ActiveMQ and publishes it into a yamcs stream

Author:

nm

Nested Class Summary

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

Modifier and Type	Field and Description
protected boolean	disabled
protected org.slf4j.Logger	log
protected long	packetcount

Constructor Summary

Constructors

Constructor and Description
ArtemisTmDataLink(String instance, String name, String artemisAddress)

Method Summary

Modifier and Type	Method and Description
void	disable() Disable any data I/O through this link.
protected void	doStart()
protected void	doStop()
void	enable() Reenable the data transit if disabled by the disable() method.
long	getDataCount()
String	getDetailedStatus()
String	getLinkStatus() Returns one of "OK" or "UNAVAIL".
boolean	isDisabled()
void	onMessage(org.apache.activemq.artemis.api.core.client.ClientMessage msg)
void	setTmSink(TmSink tmProcessor) sets the tm processor that should get all the tm packets

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

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, 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 com.google.common.util.concurrent.Service

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, startAsync, state, stopAsync

Field Detail

packetcount

protected volatile long packetcount

disabled

protected volatile boolean disabled

log

protected org.slf4j.Logger log

Constructor Detail

ArtemisTmDataLink

public ArtemisTmDataLink(String instance,
                         String name,
                         String artemisAddress)
                  throws ConfigurationException

Throws:

ConfigurationException

Method Detail

setTmSink

public void setTmSink(TmSink tmProcessor)

Description copied from interface: TmPacketDataLink

sets the tm processor that should get all the tm packets

Specified by:

setTmSink in interface TmPacketDataLink

getLinkStatus

public String getLinkStatus()

Description copied from interface: Link

Returns one of "OK" or "UNAVAIL". It's sure what the difference between uplink status and forward link status is.

Specified by:

getLinkStatus in interface Link

Returns:

disable

public void disable()

Description copied from interface: Link

Disable any data I/O through this link. Any connection to a server is closed. Can be reenabled using the enable method. Note that this method can be called before starting the service if it's configured as such in the configuration file

Specified by:

disable in interface Link

enable

public void enable()

Description copied from interface: Link

Reenable the data transit if disabled by the disable() method.

Specified by:

enable in interface Link

isDisabled

public boolean isDisabled()

Specified by:

isDisabled in interface Link

getDetailedStatus

public String getDetailedStatus()

Specified by:

getDetailedStatus in interface Link

Returns:

more detailed status information

getDataCount

public long getDataCount()

Specified by:

getDataCount in interface Link

onMessage

public void onMessage(org.apache.activemq.artemis.api.core.client.ClientMessage msg)

Specified by:

onMessage in interface org.apache.activemq.artemis.api.core.client.MessageHandler

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