org.springframework.integration.monitor

Class QueueChannelMetrics

java.lang.Object

org.springframework.integration.monitor.DirectChannelMetrics

org.springframework.integration.monitor.PollableChannelMetrics

org.springframework.integration.monitor.QueueChannelMetrics

All Implemented Interfaces:

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

public class QueueChannelMetrics
extends PollableChannelMetrics

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
QueueChannelMetrics(QueueChannel channel, java.lang.String name)

Method Summary

Methods

Modifier and Type	Method and Description
int	getQueueSize()
int	getRemainingCapacity()

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

doInvoke, getReceiveCount, getReceiveErrorCount, reset, 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

QueueChannelMetrics

public QueueChannelMetrics(QueueChannel channel,
                   java.lang.String name)

Method Detail

getQueueSize

@ManagedMetric(metricType=GAUGE,
               displayName="QueueChannel Queue Size")
public int getQueueSize()

getRemainingCapacity

@ManagedMetric(metricType=GAUGE,
               displayName="QueueChannel Remaining Capacity")
public int getRemainingCapacity()