org.apache.qpid.server.virtualhost.plugins
Class SlowConsumerDetection

java.lang.Object
  extended by org.apache.qpid.server.virtualhost.HouseKeepingTask
      extended by org.apache.qpid.server.virtualhost.plugins.VirtualHostHouseKeepingPlugin
          extended by org.apache.qpid.server.virtualhost.plugins.SlowConsumerDetection
All Implemented Interfaces:
Runnable, Plugin, VirtualHostPlugin

public class SlowConsumerDetection
extends VirtualHostHouseKeepingPlugin


Nested Class Summary
static class SlowConsumerDetection.SlowConsumerFactory
           
 
Field Summary
 
Fields inherited from class org.apache.qpid.server.virtualhost.plugins.VirtualHostHouseKeepingPlugin
_logger
 
Constructor Summary
SlowConsumerDetection(VirtualHost vhost)
           
 
Method Summary
 void configure(ConfigurationPlugin config)
          Configures the slow consumer disconnect plugin by adding a listener to each exchange on this cirtual host to record all the configured queues in a cache for processing by the housekeeping thread.
 void execute()
          Execute the plugin.
 long getDelay()
          Long value representing the delay between repeats
 TimeUnit getTimeUnit()
          Option to specify what the delay value represents
 
Methods inherited from class org.apache.qpid.server.virtualhost.HouseKeepingTask
getVirtualHost, run
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface java.lang.Runnable
run
 

Constructor Detail

SlowConsumerDetection

public SlowConsumerDetection(VirtualHost vhost)
Method Detail

configure

public void configure(ConfigurationPlugin config)
Configures the slow consumer disconnect plugin by adding a listener to each exchange on this cirtual host to record all the configured queues in a cache for processing by the housekeeping thread.

See Also:
Plugin.configure(ConfigurationPlugin)

execute

public void execute()
Description copied from class: HouseKeepingTask
Execute the plugin.

Specified by:
execute in class HouseKeepingTask

getDelay

public long getDelay()
Description copied from class: VirtualHostHouseKeepingPlugin
Long value representing the delay between repeats

Specified by:
getDelay in interface VirtualHostPlugin
Specified by:
getDelay in class VirtualHostHouseKeepingPlugin
Returns:

getTimeUnit

public TimeUnit getTimeUnit()
Description copied from class: VirtualHostHouseKeepingPlugin
Option to specify what the delay value represents

Specified by:
getTimeUnit in interface VirtualHostPlugin
Specified by:
getTimeUnit in class VirtualHostHouseKeepingPlugin
Returns:
See Also:
for valid value.


Licensed to the Apache Software Foundation