org.springframework.integration.monitor
Class QueueChannelMonitor

java.lang.Object
  org.springframework.integration.monitor.SimpleMessageChannelMonitor
      org.springframework.integration.monitor.PollableChannelMonitor
          org.springframework.integration.monitor.QueueChannelMonitor

All Implemented Interfaces:

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

public class QueueChannelMonitor
extends PollableChannelMonitor

Since:

2.0

Author:

Dave Syer

Field Summary

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

DEFAULT_MOVING_AVERAGE_WINDOW, logger, ONE_MINUTE_SECONDS, ONE_SECOND_SECONDS

Constructor Summary

QueueChannelMonitor(QueueChannel channel, String name)

Method Summary

int	getQueueSize()
int	getRemainingCapacity()

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

doInvoke, getReceiveCount, getReceiveErrorCount, toString

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

destroy, getErrorRate, getErrorRatio, getMaxSendDuration, getMeanSendDuration, getMinSendDuration, getName, getSendCount, getSendErrorCount, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend, invoke

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueChannelMonitor

public QueueChannelMonitor(QueueChannel channel,
                           String name)

Parameters:

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