diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2010-05-20 15:20:04 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2010-05-20 15:20:04 +0000 |
| commit | a733f32a1a5b541f0e134f41f63cd32f49e2563b (patch) | |
| tree | 00c99c1fadb1b4eb6cc59570dcd5175068777dc4 /java/broker | |
| parent | 440a0bc536faeb0454732153bedb1262065810d2 (diff) | |
| download | qpid-python-a733f32a1a5b541f0e134f41f63cd32f49e2563b.tar.gz | |
QPID-1447 : Modified VirtualHostHouseKeepingPlugin to return a TimeUnit and force plugin to perform validation. Potentially could be refactored to allow all VHHKPlugins to process TimeUnits in a consistent way.
Add Config validation and UnitTest for SlowConsumerDetctionConfiguration.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@946669 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker')
2 files changed, 4 insertions, 19 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java b/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java index 4a2f796d2b..2542e1e94d 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java +++ b/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java @@ -343,26 +343,9 @@ public class VirtualHostImpl implements Accessable, VirtualHost VirtualHostHouseKeepingPlugin plugin = plugins.get(pluginName).newInstance(this); - TimeUnit units = TimeUnit.MILLISECONDS; - - if (plugin.getTimeUnit() != null) - { - try - { - units = TimeUnit.valueOf(plugin.getTimeUnit()); - } - catch (IllegalArgumentException iae) - { - _logger.warn("Plugin:" + pluginName + - " provided an illegal TimeUnit value:" - + plugin.getTimeUnit()); - // Warn and use default of millseconds - // Should not occur in a well behaved plugin - } - } _houseKeepingTasks.scheduleAtFixedRate(plugin, plugin.getDelay() / 2, - plugin.getDelay(), units); + plugin.getDelay(), plugin.getTimeUnit()); _logger.info("Loaded VirtualHostPlugin:" + plugin); } diff --git a/java/broker/src/main/java/org/apache/qpid/server/virtualhost/plugins/VirtualHostHouseKeepingPlugin.java b/java/broker/src/main/java/org/apache/qpid/server/virtualhost/plugins/VirtualHostHouseKeepingPlugin.java index e76844fa3a..d2fd4daaa5 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/virtualhost/plugins/VirtualHostHouseKeepingPlugin.java +++ b/java/broker/src/main/java/org/apache/qpid/server/virtualhost/plugins/VirtualHostHouseKeepingPlugin.java @@ -23,6 +23,8 @@ package org.apache.qpid.server.virtualhost.plugins; import org.apache.qpid.server.virtualhost.HouseKeepingTask; import org.apache.qpid.server.virtualhost.VirtualHost; +import java.util.concurrent.TimeUnit; + public abstract class VirtualHostHouseKeepingPlugin extends HouseKeepingTask { public VirtualHostHouseKeepingPlugin(VirtualHost vhost) @@ -44,6 +46,6 @@ public abstract class VirtualHostHouseKeepingPlugin extends HouseKeepingTask * * @see java.util.concurrent.TimeUnit for valid value. */ - public abstract String getTimeUnit(); + public abstract TimeUnit getTimeUnit(); } |