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

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

Modifier and Type	Field and Description
protected boolean	disabled
protected Log	log
protected AtomicLong	packetcount

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	disable()
protected void	doStart()
protected void	doStop()
void	enable()
YConfiguration	getConfig()
long	getDataInCount()
long	getDataOutCount()
String	getDetailedStatus()
Link.Status	getLinkStatus()
String	getName()
boolean	isDisabled()
void	onMessage(org.apache.activemq.artemis.api.core.client.ClientMessage msg)
void	resetCounters()
void	setTmSink(TmSink tmProcessor)

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 org.yamcs.tctm.Link

getParent, setParent

Field Detail

packetcount

protected AtomicLong packetcount

disabled

protected volatile boolean disabled

log

protected Log log

Constructor Detail

ArtemisTmDataLink

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

Throws:

ConfigurationException

ArtemisTmDataLink

public ArtemisTmDataLink(String instance,
                         String name,
                         YConfiguration config)
                  throws ConfigurationException

Throws:

ConfigurationException

Method Detail

setTmSink

public void setTmSink(TmSink tmProcessor)

Specified by:

setTmSink in interface TmPacketDataLink

getLinkStatus

public Link.Status getLinkStatus()

Specified by:

getLinkStatus in interface Link

disable

public void disable()

Specified by:

disable in interface Link

enable

public void enable()

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

getDataInCount

public long getDataInCount()

Specified by:

getDataInCount in interface Link

getDataOutCount

public long getDataOutCount()

Specified by:

getDataOutCount in interface Link

resetCounters

public void resetCounters()

Specified by:

resetCounters 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

getName

public String getName()

Specified by:

getName in interface Link

getConfig

public YConfiguration getConfig()

Specified by:

getConfig in interface Link