org.yamcs

Class StreamTcCommandReleaser

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.StreamTcCommandReleaser

All Implemented Interfaces:

com.google.common.util.concurrent.Service, CommandReleaser

public class StreamTcCommandReleaser
extends com.google.common.util.concurrent.AbstractService
implements CommandReleaser

Sends commands to yamcs streams

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

Constructor Summary

Constructors

Constructor and Description
StreamTcCommandReleaser(String yamcsInstance, Map<String,String> config)

Method Summary

Modifier and Type	Method and Description
protected void	doStart()
protected void	doStop()
void	releaseCommand(PreparedCommand pc) release a command.
void	setCommandHistory(CommandHistoryPublisher commandHistoryListener) the command releaser has to add the command to the history when it is released.

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

Constructor Detail

StreamTcCommandReleaser

public StreamTcCommandReleaser(String yamcsInstance,
                               Map<String,String> config)
                        throws ConfigurationException

Throws:

ConfigurationException

Method Detail

releaseCommand

public void releaseCommand(PreparedCommand pc)

Description copied from interface: CommandReleaser

release a command.

Specified by:

releaseCommand in interface CommandReleaser

doStart

protected void doStart()

Specified by:

doStart in class com.google.common.util.concurrent.AbstractService

setCommandHistory

public void setCommandHistory(CommandHistoryPublisher commandHistoryListener)

Description copied from interface: CommandReleaser

the command releaser has to add the command to the history when it is released.

Specified by:

setCommandHistory in interface CommandReleaser

doStop

protected void doStop()

Specified by:

doStop in class com.google.common.util.concurrent.AbstractService