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 Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
filter
(List<ParameterValueWithId> params) Override to filter out some replay data.filter
(ParameterValueWithId pvwid) boolean
protected void
onParameterData
(List<ParameterValueWithId> params) protected void
abstract void
abstract void
void
void
setNoRepeat
(boolean noRepeat) void
terminated
(com.google.common.util.concurrent.Service.State from) void
update
(int subscriptionId, List<ParameterValueWithId> params) void
update
(ParameterValueWithId pvwid) Methods inherited from class com.google.common.util.concurrent.Service.Listener
running, starting, stopping
-
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
- Overrides:
failed
in classcom.google.common.util.concurrent.Service.Listener
-
terminated
public void terminated(com.google.common.util.concurrent.Service.State from) - Overrides:
terminated
in classcom.google.common.util.concurrent.Service.Listener
-
update
- Specified by:
update
in interfaceParameterWithIdConsumer
-
update
-
filter
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
-
onParameterData
-
onParameterData
-
replayFinished
public abstract void replayFinished() -
replayFailed
-