org.springframework.integration.monitor

Class PollableChannelMetrics

java.lang.Object

org.springframework.integration.monitor.DirectChannelMetrics

org.springframework.integration.monitor.PollableChannelMetrics

All Implemented Interfaces:

org.aopalliance.aop.Advice, org.aopalliance.intercept.Interceptor, org.aopalliance.intercept.MethodInterceptor, MessageChannelMetrics

Direct Known Subclasses:

QueueChannelMetrics

public class PollableChannelMetrics
extends DirectChannelMetrics

Since:

2.0

Author:

Dave Syer

Field Summary

Fields inherited from class org.springframework.integration.monitor.DirectChannelMetrics

DEFAULT_MOVING_AVERAGE_WINDOW, logger, ONE_MINUTE_SECONDS, ONE_SECOND_SECONDS

Constructor Summary

Constructors

Constructor and Description
PollableChannelMetrics(MessageChannel messageChannel, String name)

Method Summary

Methods

Modifier and Type	Method and Description
protected Object	doInvoke(org.aopalliance.intercept.MethodInvocation invocation, String method, MessageChannel channel)
int	getReceiveCount()
int	getReceiveErrorCount()
void	reset()
String	toString()

Methods inherited from class org.springframework.integration.monitor.DirectChannelMetrics

destroy, getErrorRate, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMessageChannel, getMinSendDuration, getName, getSendCount, getSendDuration, getSendErrorCount, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend, invoke

Methods inherited from class java.lang.Object

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

Constructor Detail

PollableChannelMetrics

public PollableChannelMetrics(MessageChannel messageChannel,
                      String name)

Method Detail

doInvoke

protected Object doInvoke(org.aopalliance.intercept.MethodInvocation invocation,
              String method,
              MessageChannel channel)
                   throws Throwable

Overrides:

doInvoke in class DirectChannelMetrics

Throws:

Throwable

reset

@ManagedOperation
public void reset()

Specified by:

reset in interface MessageChannelMetrics

Overrides:

reset in class DirectChannelMetrics

getReceiveCount

@ManagedMetric(metricType=COUNTER,
               displayName="MessageChannel Receive Count")
public int getReceiveCount()

getReceiveErrorCount

@ManagedMetric(metricType=COUNTER,
               displayName="MessageChannel Receive Error Count")
public int getReceiveErrorCount()

toString

public String toString()

Overrides:

toString in class DirectChannelMetrics