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

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

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

destroy, getErrorRate, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMessageChannel, getMinSendDuration, getName, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, 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()

getReceiveCountLong

@ManagedMetric(metricType=COUNTER,
               displayName="MessageChannel Receive Count")
public long getReceiveCountLong()

getReceiveErrorCount

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

getReceiveErrorCountLong

@ManagedMetric(metricType=COUNTER,
               displayName="MessageChannel Receive Error Count")
public long getReceiveErrorCountLong()

toString

public String toString()

Overrides:

toString in class DirectChannelMetrics