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
     
  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
     
    protected void
     
    void
    onTuple(Stream s, Tuple tuple)
     
    void
     
    void
     

    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