org.springframework.integration.support.management

Class DefaultMessageHandlerMetrics

java.lang.Object

org.springframework.integration.support.management.AbstractMessageHandlerMetrics

org.springframework.integration.support.management.DefaultMessageHandlerMetrics

All Implemented Interfaces:

ConfigurableMetrics

Direct Known Subclasses:

AggregatingMessageHandlerMetrics

public class DefaultMessageHandlerMetrics
extends AbstractMessageHandlerMetrics

Default implementation; use the full constructor to customize the moving averages.

Since:

2.0

Author:

Dave Syer, Gary Russell

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	DefaultMessageHandlerMetrics.DefaultHandlerMetricsContext

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicLong	activeCount
protected ExponentialMovingAverage	duration
protected AtomicLong	errorCount
protected AtomicLong	handleCount

Fields inherited from class org.springframework.integration.support.management.AbstractMessageHandlerMetrics

logger, name

Constructor Summary

Constructors

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).

Method Summary

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()

Methods inherited from class org.springframework.integration.support.management.AbstractMessageHandlerMetrics

isFullStatsEnabled, setFullStatsEnabled

Methods inherited from class java.lang.Object

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

Field Detail

activeCount

protected final AtomicLong activeCount

handleCount

protected final AtomicLong handleCount

errorCount

protected final AtomicLong errorCount

duration

protected final ExponentialMovingAverage duration

Constructor Detail

DefaultMessageHandlerMetrics

public DefaultMessageHandlerMetrics()

DefaultMessageHandlerMetrics

public DefaultMessageHandlerMetrics(String name)

Construct an instance with the default moving average window (10).

Parameters:

name - the name.

DefaultMessageHandlerMetrics

public 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).

Parameters:

name - the name.

duration - an ExponentialMovingAverage for calculating the duration.

Since:

4.2

Method Detail

beforeHandle

public MetricsContext beforeHandle()

Description copied from class: AbstractMessageHandlerMetrics

Begin a handle event.

Specified by:

beforeHandle in class AbstractMessageHandlerMetrics

Returns:

the context to be used in the AbstractMessageHandlerMetrics.afterHandle(MetricsContext, boolean).

afterHandle

public void afterHandle(MetricsContext context,
                        boolean success)

Description copied from class: AbstractMessageHandlerMetrics

End a handle event

Specified by:

afterHandle in class AbstractMessageHandlerMetrics

Parameters:

context - the context from the previous AbstractMessageHandlerMetrics.beforeHandle().

success - true for success, false otherwise.

reset

public void reset()

Specified by:

reset in class AbstractMessageHandlerMetrics

getHandleCountLong

public long getHandleCountLong()

Specified by:

getHandleCountLong in class AbstractMessageHandlerMetrics

getHandleCount

public int getHandleCount()

Specified by:

getHandleCount in class AbstractMessageHandlerMetrics

getErrorCount

public int getErrorCount()

Specified by:

getErrorCount in class AbstractMessageHandlerMetrics

getErrorCountLong

public long getErrorCountLong()

Specified by:

getErrorCountLong in class AbstractMessageHandlerMetrics

getMeanDuration

public double getMeanDuration()

Specified by:

getMeanDuration in class AbstractMessageHandlerMetrics

getMinDuration

public double getMinDuration()

Specified by:

getMinDuration in class AbstractMessageHandlerMetrics

getMaxDuration

public double getMaxDuration()

Specified by:

getMaxDuration in class AbstractMessageHandlerMetrics

getStandardDeviationDuration

public double getStandardDeviationDuration()

Specified by:

getStandardDeviationDuration in class AbstractMessageHandlerMetrics

getActiveCount

public int getActiveCount()

Specified by:

getActiveCount in class AbstractMessageHandlerMetrics

getActiveCountLong

public long getActiveCountLong()

Specified by:

getActiveCountLong in class AbstractMessageHandlerMetrics

getDuration

public Statistics getDuration()

Specified by:

getDuration in class AbstractMessageHandlerMetrics