public class EventProcessorLatencyMonitor extends Object implements MessageMonitor<EventMessage<?>>, com.codahale.metrics.MetricSet
MessageMonitorimplementation dedicated to
This monitor defines the latency between the
EventMessage.getTimestamp() and the
Doing so, it depicts the latency from when an event was published compared to when an
EventProcessor processes the event to clarify how far behind an
Do note that a replay (as triggered through
StreamingEventProcessor.resetTokens(), for example) will cause
this metric to bump up due to the processor handling old events.
|Constructor and Description|
|Modifier and Type||Method and Description|
Takes a message and returns a callback that should be used to inform the message monitor about the result of processing the message
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public MessageMonitor.MonitorCallback onMessageIngested(@Nonnull EventMessage<?> message)
Copyright © 2010–2023. All rights reserved.