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

PollableChannelMetrics(MessageChannel messageChannel, java.lang.String name)

Method Summary

protected java.lang.Object	doInvoke(org.aopalliance.intercept.MethodInvocation invocation, java.lang.String method, MessageChannel channel)
int	getReceiveCount()
int	getReceiveErrorCount()
void	reset()
java.lang.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,
                              java.lang.String name)

Method Detail

doInvoke

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

Overrides:

doInvoke in class DirectChannelMetrics

Throws:

java.lang.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 java.lang.String toString()

Overrides:

toString in class DirectChannelMetrics