org.apache.qpid.server.virtualhost.plugins
Class SlowConsumerDetection
java.lang.Object
org.apache.qpid.server.virtualhost.HouseKeepingTask
org.apache.qpid.server.virtualhost.plugins.VirtualHostHouseKeepingPlugin
org.apache.qpid.server.virtualhost.plugins.SlowConsumerDetection
- All Implemented Interfaces:
- Runnable, Plugin, VirtualHostPlugin
public class SlowConsumerDetection
- extends VirtualHostHouseKeepingPlugin
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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface java.lang.Runnable |
run |
SlowConsumerDetection
public SlowConsumerDetection(VirtualHost vhost)
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