Package org.yamcs

Class StreamTmPacketProvider

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.AbstractProcessorService

org.yamcs.StreamTmPacketProvider

All Implemented Interfaces:

com.google.common.util.concurrent.Service, ProcessorService, TmPacketProvider

public class StreamTmPacketProvider
extends AbstractProcessorService
implements TmPacketProvider

Receives packets from yamcs streams and sends them to the Processor/TmProcessor for extraction of parameters. Can read from multiple streams, each with its own root container used as start of XTCE packet processing

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 inherited from class org.yamcs.AbstractProcessorService

config, log, processor

Constructor Summary

Constructors

Constructor	Description
StreamTmPacketProvider()

Method Summary

Modifier and Type	Method	Description
protected void	doStart()
protected void	doStop()
void	init(Processor proc, YConfiguration config, Object spec)
boolean	isArchiveReplay()	true if this is a replay from archive

Methods inherited from class org.yamcs.AbstractProcessorService

getConfig, getYamcsInstance

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

getSpec

Methods inherited from interface com.google.common.util.concurrent.Service

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

Constructor Detail

StreamTmPacketProvider

public StreamTmPacketProvider()

Method Detail

init

public void init(Processor proc,
                 YConfiguration config,
                 Object spec)

Specified by:

init in interface ProcessorService

Overrides:

init in class AbstractProcessorService

config - service configuration as specified in processor.yaml

spec - passed by the user when creating the processor (for instance via the REST API)

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

isArchiveReplay

public boolean isArchiveReplay()

Description copied from interface: TmPacketProvider

true if this is a replay from archive

Specified by:

isArchiveReplay in interface TmPacketProvider

Returns: