Package com.framed.streamer.dispatcher

Class JsonlDispatcher

java.lang.Object

com.framed.core.Service

com.framed.io.dispatch.Dispatcher

com.framed.streamer.dispatcher.JsonlDispatcher

public class JsonlDispatcher
extends Dispatcher

Field Summary

Fields inherited from class com.framed.core.Service

ADDRESS_REGISTRY_SUFFIX, eventBus, formatter, logger

Constructor Summary

Constructors

Constructor	Description
JsonlDispatcher(EventBus eventBus, org.json.JSONArray devices, String path, String fileName)

Method Summary

Modifier and Type	Method	Description
protected void	onDrop(DataPoint<?> dp, Throwable cause)	Called when datapoint cannot be queued or pushed.
protected void	onHandlerError(String deviceID, String address, Object rawMsg, Exception e)	Called when handler fails before enqueueing (e.g., parse error).
void	push(DataPoint<?> dataPoint)	Pushes a single datapoint to the underlying sink.
void	pushBatch(List<DataPoint<?>> batch)	Pushes a batch of datapoints to the underlying sink.

Methods inherited from class com.framed.io.dispatch.Dispatcher

shutdown, stop

Methods inherited from class com.framed.core.Service

addressRegistry, announceAddress

Methods inherited from class java.lang.Object

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

Constructor Details

JsonlDispatcher

public JsonlDispatcher(EventBus eventBus,
 org.json.JSONArray devices,
 String path,
 String fileName)

Method Details

push

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

Description copied from class: Dispatcher

Pushes a single datapoint to the underlying sink.

Invoked on the dispatcher's worker thread. Implementations may throw IOException to signal a transient failure, which triggers retry with exponential backoff.

Specified by:

push in class Dispatcher

Parameters:

dataPoint - the datapoint to push

Throws:

IOException - if the push fails due to a transient IO error and should be retried

pushBatch

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

Description copied from class: Dispatcher

Pushes a batch of datapoints to the underlying sink.

Specified by:

pushBatch in class Dispatcher

Parameters:

batch - the datapoints to push

onHandlerError

protected void onHandlerError(String deviceID,
 String address,
 Object rawMsg,
 Exception e)

Description copied from class: Dispatcher

Called when handler fails before enqueueing (e.g., parse error). Override to write dead-letter files, metrics, etc.

Overrides:

onHandlerError in class Dispatcher

Parameters:

deviceID - the identifier of the device whose message failed to be handled

address - the channel address the failing message arrived on

rawMsg - the raw, unparsed message payload

e - the exception raised while handling the message

onDrop

protected void onDrop(DataPoint<?> dp,
 Throwable cause)

Description copied from class: Dispatcher

Called when datapoint cannot be queued or pushed. Override for dead-letter storage / metrics.

Overrides:

onDrop in class Dispatcher

Parameters:

dp - the datapoint that could not be queued or pushed

cause - the reason the datapoint was dropped