diff options
Diffstat (limited to 'java/broker-plugins/experimental')
2 files changed, 10 insertions, 18 deletions
diff --git a/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/SlowConsumerDetection.java b/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/SlowConsumerDetection.java index 6b5be4a9e2..73ba91f1e8 100644 --- a/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/SlowConsumerDetection.java +++ b/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/SlowConsumerDetection.java @@ -38,32 +38,24 @@ class SlowConsumerDetection extends VirtualHostHouseKeepingPlugin public static class SlowConsumerFactory implements VirtualHostPluginFactory { - public Class<SlowConsumerDetection> getPluginClass() + public SlowConsumerDetection newInstance(VirtualHost vhost) { - return SlowConsumerDetection.class; - } + SlowConsumerDetectionConfiguration config = vhost.getConfiguration().getConfiguration(SlowConsumerDetectionConfiguration.class); - public String getPluginName() - { - return SlowConsumerDetection.class.getName(); - } + if (config == null) + { + return null; + } - public SlowConsumerDetection newInstance(VirtualHost vhost) throws ConfigurationException - { SlowConsumerDetection plugin = new SlowConsumerDetection(vhost); - plugin.configure(vhost.getConfiguration()); + plugin.configure(config); return plugin; } } - public void configure(ConfigurationPlugin config) throws ConfigurationException + public void configure(ConfigurationPlugin config) { - _config = config.getConfiguration(SlowConsumerDetectionConfiguration.class); - - if (_config == null) - { - throw new IllegalArgumentException("Plugin has not been configured"); - } + _config = (SlowConsumerDetectionConfiguration) config; } public SlowConsumerDetection(VirtualHost vhost) diff --git a/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/policies/TopicDeletePolicy.java b/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/policies/TopicDeletePolicy.java index 5262042b17..9bd1dd304f 100644 --- a/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/policies/TopicDeletePolicy.java +++ b/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/policies/TopicDeletePolicy.java @@ -128,7 +128,7 @@ public class TopicDeletePolicy implements SlowConsumerPolicyPlugin return false; } - public void configure(ConfigurationPlugin config) throws ConfigurationException + public void configure(ConfigurationPlugin config) { _configuration = (TopicDeletePolicyConfiguration) config; } |