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

Constructors

Constructor	Description
ParameterReplayListener()
ParameterReplayListener(long pos, int limit)

Method Summary

Modifier and Type	Method	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)
abstract void	replayFailed(Throwable t)
abstract void	replayFinished()
void	requestReplayAbortion()
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

Methods inherited from class java.lang.Object

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

Constructor Detail

ParameterReplayListener

public ParameterReplayListener()

ParameterReplayListener

public ParameterReplayListener(long pos,
                               int limit)

Method Detail

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)