org.yamcs.web.rest

Class RestReplayListener

java.lang.Object

com.google.common.util.concurrent.Service.Listener

org.yamcs.web.rest.RestReplayListener

All Implemented Interfaces:

ParameterWithIdConsumer

Direct Known Subclasses:

RestParameterReplayListener

public abstract class RestReplayListener
extends com.google.common.util.concurrent.Service.Listener
implements ParameterWithIdConsumer

Expected class type for use with RestReplays Adds functionality for stopping a replay, and has support for pagination

Constructor Summary

Constructors

Constructor and Description
RestReplayListener()
RestReplayListener(long pos, int limit)

Method Summary

Modifier and Type	Method and Description
void	failed(com.google.common.util.concurrent.Service.State from, Throwable failure)
List<ParameterValueWithId>	filter(List<ParameterValueWithId> params) Override to filter out some replay data.
ParameterValueWithId	filter(ParameterValueWithId pvwid)
boolean	isReplayAbortRequested()
protected void	onParameterData(List<ParameterValueWithId> params)
protected void	onParameterData(ParameterValueWithId pvwid)
void	replayFailed(Throwable t)
void	replayFinished()
void	requestReplayAbortion()
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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RestReplayListener

public RestReplayListener()

RestReplayListener

public RestReplayListener(long pos,
                          int limit)

Method Detail

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 void replayFinished()

replayFailed

public void replayFailed(Throwable t)