Module org.yamcs.core

Package org.yamcs.parameterarchive

Class BackFiller

java.lang.Object

org.yamcs.parameterarchive.BackFiller

All Implemented Interfaces:

StreamSubscriber

public class BackFiller
extends Object
implements StreamSubscriber

Back-fills the parameter archive by triggering replays: - either regularly scheduled replays - or monitor data streams (tm, param) and keep track of which segments have to be rebuild

Method Summary

Modifier and Type	Method	Description
void	addListener(BackFillerListener listener)
void	enableAutomaticBackfilling(boolean enable)
static Spec	getSpec()
void	onTuple(Stream stream, Tuple tuple)
void	removeListener(BackFillerListener listener)
Future<?>	scheduleFillingTask(long start, long stop)
void	shutDown()
void	streamClosed(Stream stream)

Methods inherited from class java.lang.Object

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

Method Details

getSpec

public static Spec getSpec()

enableAutomaticBackfilling

public void enableAutomaticBackfilling(boolean enable)

scheduleFillingTask

public Future<?> scheduleFillingTask(long start,
 long stop)

shutDown

public void shutDown()
              throws InterruptedException

Throws:

InterruptedException

onTuple

public void onTuple(Stream stream,
 Tuple tuple)

Specified by:

onTuple in interface StreamSubscriber

streamClosed

public void streamClosed(Stream stream)

Specified by:

streamClosed in interface StreamSubscriber

addListener

public void addListener(BackFillerListener listener)

removeListener

public void removeListener(BackFillerListener listener)