public class DefaultMessageHandlerMetrics extends AbstractMessageHandlerMetrics
Modifier and Type | Class and Description |
---|---|
protected static class |
DefaultMessageHandlerMetrics.DefaultHandlerMetricsContext |
Modifier and Type | Field and Description |
---|---|
protected AtomicLong |
activeCount |
protected ExponentialMovingAverage |
duration |
protected AtomicLong |
errorCount |
protected AtomicLong |
handleCount |
logger, name
Constructor and Description |
---|
DefaultMessageHandlerMetrics() |
DefaultMessageHandlerMetrics(String name)
Construct an instance with the default moving average window (10).
|
DefaultMessageHandlerMetrics(String name,
ExponentialMovingAverage duration)
Construct an instance with the supplied
ExponentialMovingAverage calculating
the duration of processing by the message handler (and any downstream synchronous
endpoints). |
Modifier and Type | Method and Description |
---|---|
void |
afterHandle(MetricsContext context,
boolean success)
End a handle event
|
MetricsContext |
beforeHandle()
Begin a handle event.
|
int |
getActiveCount() |
long |
getActiveCountLong() |
Statistics |
getDuration() |
int |
getErrorCount() |
long |
getErrorCountLong() |
int |
getHandleCount() |
long |
getHandleCountLong() |
double |
getMaxDuration() |
double |
getMeanDuration() |
double |
getMinDuration() |
double |
getStandardDeviationDuration() |
void |
reset() |
isFullStatsEnabled, setFullStatsEnabled
protected final AtomicLong activeCount
protected final AtomicLong handleCount
protected final AtomicLong errorCount
protected final ExponentialMovingAverage duration
public DefaultMessageHandlerMetrics()
public DefaultMessageHandlerMetrics(String name)
name
- the name.public DefaultMessageHandlerMetrics(String name, ExponentialMovingAverage duration)
ExponentialMovingAverage
calculating
the duration of processing by the message handler (and any downstream synchronous
endpoints).name
- the name.duration
- an ExponentialMovingAverage
for calculating the duration.public MetricsContext beforeHandle()
AbstractMessageHandlerMetrics
beforeHandle
in class AbstractMessageHandlerMetrics
AbstractMessageHandlerMetrics.afterHandle(MetricsContext, boolean)
.public void afterHandle(MetricsContext context, boolean success)
AbstractMessageHandlerMetrics
afterHandle
in class AbstractMessageHandlerMetrics
context
- the context from the previous AbstractMessageHandlerMetrics.beforeHandle()
.success
- true for success, false otherwise.public void reset()
reset
in class AbstractMessageHandlerMetrics
public long getHandleCountLong()
getHandleCountLong
in class AbstractMessageHandlerMetrics
public int getHandleCount()
getHandleCount
in class AbstractMessageHandlerMetrics
public int getErrorCount()
getErrorCount
in class AbstractMessageHandlerMetrics
public long getErrorCountLong()
getErrorCountLong
in class AbstractMessageHandlerMetrics
public double getMeanDuration()
getMeanDuration
in class AbstractMessageHandlerMetrics
public double getMinDuration()
getMinDuration
in class AbstractMessageHandlerMetrics
public double getMaxDuration()
getMaxDuration
in class AbstractMessageHandlerMetrics
public double getStandardDeviationDuration()
getStandardDeviationDuration
in class AbstractMessageHandlerMetrics
public int getActiveCount()
getActiveCount
in class AbstractMessageHandlerMetrics
public long getActiveCountLong()
getActiveCountLong
in class AbstractMessageHandlerMetrics
public Statistics getDuration()
getDuration
in class AbstractMessageHandlerMetrics