summaryrefslogtreecommitdiff
path: root/java/broker-plugins/experimental
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2010-06-03 21:26:59 +0000
committerMartin Ritchie <ritchiem@apache.org>2010-06-03 21:26:59 +0000
commit388d42d6be196afb5f9803278a45f46199dc9e30 (patch)
treeb34885c6e8e1695c84deb499c9704fe86732fba8 /java/broker-plugins/experimental
parent9bcd23b23e46bb94761611f65d1afddfb927a94a (diff)
downloadqpid-python-388d42d6be196afb5f9803278a45f46199dc9e30.tar.gz
Remove Plugin.isConfigured Only configured plugins should be created
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@951158 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker-plugins/experimental')
-rw-r--r--java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/SlowConsumerDetection.java11
-rw-r--r--java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/policies/TopicDeletePolicy.java7
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;