Class TrackerMonitor

java.lang.Object

io.fluxzero.sdk.tracking.metrics.TrackerMonitor

All Implemented Interfaces:

BatchInterceptor

public class TrackerMonitor
extends Object
implements BatchInterceptor

Constructor Summary

Constructors

Constructor	Description
TrackerMonitor()

Method Summary

Modifier and Type	Method	Description
Consumer<MessageBatch>	intercept(Consumer<MessageBatch> consumer, Tracker tracker)	Intercepts the given batch message consumer and returns a decorated version to be invoked by the tracker.

Methods inherited from class Object

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

Methods inherited from interface BatchInterceptor

andThen, shutdown

Constructor Details

TrackerMonitor

public TrackerMonitor()

Method Details

intercept

public Consumer<MessageBatch> intercept(Consumer<MessageBatch> consumer,
 Tracker tracker)

Description copied from interface: BatchInterceptor

Intercepts the given batch message consumer and returns a decorated version to be invoked by the tracker.

Specified by:

intercept in interface BatchInterceptor

Parameters:

consumer - the original consumer that processes the MessageBatch

tracker - the tracker invoking this interceptor

Returns:

a wrapped consumer with additional behavior