Package org.yamcs.cmdhistory

Class StreamCommandHistoryProvider

java.lang.Object
com.google.common.util.concurrent.AbstractService
org.yamcs.cmdhistory.StreamCommandHistoryProvider
All Implemented Interfaces:
com.google.common.util.concurrent.Service, CommandHistoryProvider, StreamSubscriber
public class StreamCommandHistoryProvider extends com.google.common.util.concurrent.AbstractService implements CommandHistoryProvider, StreamSubscriber
provides command history from streams

  • 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
    Description
    StreamCommandHistoryProvider(String yamcsInstance)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    doStart()
     
    protected void
    doStop()
     
    void
    onTuple(Stream s, Tuple tuple)
     
    void
    setCommandHistoryRequestManager(CommandHistoryRequestManager chrm)
     
    void
    streamClosed(Stream stream)
     

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

    addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, 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, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, failureCause, isRunning, startAsync, state, stopAsync

  • Constructor Details

    • StreamCommandHistoryProvider

      public StreamCommandHistoryProvider(String yamcsInstance)

  • Method Details