Module org.yamcs.core
Package org.yamcs.http.api

Class ParameterReplayListener

java.lang.Object
com.google.common.util.concurrent.Service.Listener
org.yamcs.http.api.ParameterReplayListener
All Implemented Interfaces:
ParameterWithIdConsumer
public abstract class ParameterReplayListener extends com.google.common.util.concurrent.Service.Listener implements ParameterWithIdConsumer
Expected class type for use with ReplayFactory Adds functionality for stopping a replay, and has support for pagination

  • Constructor Details

    • ParameterReplayListener

      public ParameterReplayListener()

    • ParameterReplayListener

      public ParameterReplayListener(long pos, int limit)

  • Method Details

    • setNoRepeat

      public void setNoRepeat(boolean noRepeat)

    • requestReplayAbortion

      public void requestReplayAbortion()

    • isReplayAbortRequested

      public boolean isReplayAbortRequested()

    • failed

      public void failed(com.google.common.util.concurrent.Service.State from, Throwable failure)
      Overrides:
      failed in class com.google.common.util.concurrent.Service.Listener

    • terminated

      public void terminated(com.google.common.util.concurrent.Service.State from)
      Overrides:
      terminated in class com.google.common.util.concurrent.Service.Listener

    • update

      public void update(int subscriptionId, List<ParameterValueWithId> params)
      Specified by:
      update in interface ParameterWithIdConsumer

    • update

      public void update(ParameterValueWithId pvwid)

    • filter

      public List<ParameterValueWithId> filter(List<ParameterValueWithId> params)
      Override to filter out some replay data. Null means excluded. (which also means it will not be counted towards the pagination).
      Returns:
      filtered data

    • filter

      public ParameterValueWithId filter(ParameterValueWithId pvwid)

    • onParameterData

      protected void onParameterData(List<ParameterValueWithId> params)

    • onParameterData

      protected void onParameterData(ParameterValueWithId pvwid)

    • replayFinished

      public abstract void replayFinished()

    • replayFailed

      public abstract void replayFailed(Throwable t)