Package com.framed.streamer.dispatcher

Class FfillDispatcher

java.lang.Object

com.framed.core.Service

com.framed.streamer.dispatcher.Dispatcher

com.framed.streamer.dispatcher.FfillDispatcher

public class FfillDispatcher
extends Dispatcher

Field Summary

Fields inherited from class com.framed.core.Service

eventBus, formatter, logger

Constructor Summary

Constructors

Constructor	Description
FfillDispatcher(EventBus eventBus, org.json.JSONArray devices, Long frequencyMillis)

Method Summary

Modifier and Type	Method	Description
void	push(DataPoint<?> dataPoint)
void	pushBatch(List<DataPoint<?>> timeSeries)
void	stop()	Stops the service.

Methods inherited from class java.lang.Object

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

Constructor Details

FfillDispatcher

public FfillDispatcher(EventBus eventBus,
 org.json.JSONArray devices,
 Long frequencyMillis)

Method Details

push

public void push(DataPoint<?> dataPoint)
          throws IOException

Specified by:

push in class Dispatcher

Throws:

IOException

pushBatch

public void pushBatch(List<DataPoint<?>> timeSeries)

Specified by:

pushBatch in class Dispatcher

stop

public void stop()

Description copied from class: Service

Stops the service.

By default, this method logs a message indicating that no stop logic is implemented. Subclasses should override this method to provide custom shutdown behavior when necessary.

Overrides:

stop in class Service