public class MessageCountingMonitor extends Object implements MessageMonitor<Message<?>>, com.codahale.metrics.MetricSet
MessageMonitor.MonitorCallback
Constructor and Description |
---|
MessageCountingMonitor() |
Modifier and Type | Method and Description |
---|---|
Map<String,com.codahale.metrics.Metric> |
getMetrics() |
MessageMonitor.MonitorCallback |
onMessageIngested(Message<?> message)
Takes a message and returns a callback that should be used
to inform the message monitor about the result of processing the message
|
public MessageMonitor.MonitorCallback onMessageIngested(Message<?> message)
MessageMonitor
onMessageIngested
in interface MessageMonitor<Message<?>>
message
- the message to monitorCopyright © 2010–2017. All rights reserved.