Package org.yamcs
Class StreamTcCommandReleaser
- java.lang.Object
-
- com.google.common.util.concurrent.AbstractService
-
- org.yamcs.AbstractProcessorService
-
- org.yamcs.StreamTcCommandReleaser
-
- All Implemented Interfaces:
com.google.common.util.concurrent.Service,CommandReleaser,ProcessorService
public class StreamTcCommandReleaser extends AbstractProcessorService implements CommandReleaser
Sends commands to yamcs streams
-
-
Field Summary
-
Fields inherited from class org.yamcs.AbstractProcessorService
config, log, processor
-
-
Constructor Summary
Constructors Constructor Description StreamTcCommandReleaser()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voiddoStart()protected voiddoStop()voidinit(Processor proc, YConfiguration config, Object spec)voidreleaseCommand(PreparedCommand pc)release a command.voidsetCommandHistory(CommandHistoryPublisher commandHistoryPublisher)the command releaser has to add the command to the history when it is released.-
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
-
-
-
-
Method Detail
-
init
public void init(Processor proc, YConfiguration config, Object spec)
- Specified by:
initin interfaceProcessorService- Overrides:
initin classAbstractProcessorServiceconfig- service configuration as specified in processor.yamlspec- passed by the user when creating the processor (for instance via the REST API)
-
releaseCommand
public void releaseCommand(PreparedCommand pc)
Description copied from interface:CommandReleaserrelease a command.- Specified by:
releaseCommandin interfaceCommandReleaser
-
doStart
protected void doStart()
- Specified by:
doStartin classcom.google.common.util.concurrent.AbstractService
-
setCommandHistory
public void setCommandHistory(CommandHistoryPublisher commandHistoryPublisher)
Description copied from interface:CommandReleaserthe command releaser has to add the command to the history when it is released.- Specified by:
setCommandHistoryin interfaceCommandReleaser
-
doStop
protected void doStop()
- Specified by:
doStopin classcom.google.common.util.concurrent.AbstractService
-
-