diff options
Diffstat (limited to 'java/broker-plugins/experimental')
2 files changed, 2 insertions, 16 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 9dd0ec47ec..6b5be4a9e2 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 @@ -57,7 +57,7 @@ class SlowConsumerDetection extends VirtualHostHouseKeepingPlugin } public void configure(ConfigurationPlugin config) throws ConfigurationException - { + { _config = config.getConfiguration(SlowConsumerDetectionConfiguration.class); if (_config == null) @@ -144,13 +144,4 @@ class SlowConsumerDetection extends VirtualHostHouseKeepingPlugin return false; } - public boolean isConfigured() - { - return _config != null && _virtualhost != null; - } - - public void configure() throws ConfigurationException - { - // Empty - } } 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 05ff75f138..5262042b17 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 @@ -46,7 +46,7 @@ public class TopicDeletePolicy implements SlowConsumerPolicyPlugin { TopicDeletePolicyConfiguration config = configuration.getConfiguration(TopicDeletePolicyConfiguration.class); - + TopicDeletePolicy policy = new TopicDeletePolicy(); policy.configure(config); return policy; @@ -128,11 +128,6 @@ public class TopicDeletePolicy implements SlowConsumerPolicyPlugin return false; } - public boolean isConfigured() - { - return _configuration != null; - } - public void configure(ConfigurationPlugin config) throws ConfigurationException { _configuration = (TopicDeletePolicyConfiguration) config; |