From c14e5d4b2a3bdcd45e4af44c3a641ad391873f4e Mon Sep 17 00:00:00 2001 From: Martin Ritchie Date: Mon, 14 Jun 2010 12:34:48 +0000 Subject: Update LogMessage Generation to be based on a the existance of a _logmessages.property file. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@954431 13f79535-47bb-0310-9956-ffa450edef68 --- .../experimental/slowconsumerdetection/build.xml | 28 +++++++++++++++------- .../virtualhost/plugin/SlowConsumerDetection.java | 6 ++--- .../plugin/logging/LogMessages.properties | 10 -------- .../SlowConsumerDetection_logmessages.properties | 4 ++++ .../TopicDeletePolicy_logmessages.properties | 3 +++ .../plugin/policies/TopicDeletePolicy.java | 4 ++-- 6 files changed, 32 insertions(+), 23 deletions(-) delete mode 100644 java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/logging/LogMessages.properties create mode 100644 java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/logging/SlowConsumerDetection_logmessages.properties create mode 100644 java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/logging/TopicDeletePolicy_logmessages.properties (limited to 'java/broker-plugins') diff --git a/java/broker-plugins/experimental/slowconsumerdetection/build.xml b/java/broker-plugins/experimental/slowconsumerdetection/build.xml index 4893de6886..340d749ecc 100644 --- a/java/broker-plugins/experimental/slowconsumerdetection/build.xml +++ b/java/broker-plugins/experimental/slowconsumerdetection/build.xml @@ -39,7 +39,7 @@ nn - or more contributor license agreements. See the NOTICE file - + @@ -56,14 +56,26 @@ nn - or more contributor license agreements. See the NOTICE file + + + + + + + + + + + - - - - - - - + + + + + + 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 71071d4d90..77819f8dbf 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 @@ -66,11 +66,11 @@ class SlowConsumerDetection extends VirtualHostHouseKeepingPlugin @Override public void execute() { - SlowConsumerDetectionMessages.SCD_RUNNING(); + SlowConsumerDetectionMessages.RUNNING(); for (AMQQueue q : _virtualhost.getQueueRegistry().getQueues()) { - SlowConsumerDetectionMessages.SCD_CHECKING_QUEUE(q.getName()); + SlowConsumerDetectionMessages.CHECKING_QUEUE(q.getName()); try { SlowConsumerDetectionQueueConfiguration config = @@ -91,7 +91,7 @@ class SlowConsumerDetection extends VirtualHostHouseKeepingPlugin } } - SlowConsumerDetectionMessages.SCD_COMPLETE(); + SlowConsumerDetectionMessages.COMPLETE(); } public long getDelay() diff --git a/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/logging/LogMessages.properties b/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/logging/LogMessages.properties deleted file mode 100644 index 7243e144ad..0000000000 --- a/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/logging/LogMessages.properties +++ /dev/null @@ -1,10 +0,0 @@ -#SlowConsumerDetection.logMessages -SCD=SlowConsumerDetection -SCD_RUNNING = SCD-1001 : Running -SCD_COMPLETE = SCD-1002 : Complete -SCD_CHECKING_QUEUE = SCD-1003 : Checking Status of Queue {0} - -#TopicDeletePolicy.logMessages -TDP=TopicDeletePolicy -TDP_DELETING_QUEUE = TDP-1001 : Deleting Queue -TDP_DISCONNECTING = TDP-1002 : Disconnecting Session \ No newline at end of file diff --git a/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/logging/SlowConsumerDetection_logmessages.properties b/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/logging/SlowConsumerDetection_logmessages.properties new file mode 100644 index 0000000000..2714935a71 --- /dev/null +++ b/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/logging/SlowConsumerDetection_logmessages.properties @@ -0,0 +1,4 @@ +#SlowConsumerDetection.logMessages +RUNNING = SCD-1001 : Running +COMPLETE = SCD-1002 : Complete +CHECKING_QUEUE = SCD-1003 : Checking Status of Queue {0} \ No newline at end of file diff --git a/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/logging/TopicDeletePolicy_logmessages.properties b/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/logging/TopicDeletePolicy_logmessages.properties new file mode 100644 index 0000000000..d0f5965c39 --- /dev/null +++ b/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/logging/TopicDeletePolicy_logmessages.properties @@ -0,0 +1,3 @@ +#TopicDeletePolicy.logMessages +DELETING_QUEUE = TDP-1001 : Deleting Queue +DISCONNECTING = TDP-1002 : Disconnecting Session \ No newline at end of file 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 577dced7d8..3c67f6e6d7 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 @@ -86,7 +86,7 @@ public class TopicDeletePolicy implements SlowConsumerPolicyPlugin try { - CurrentActor.get().message(owner.getLogSubject(),TopicDeletePolicyMessages.TDP_DISCONNECTING()); + CurrentActor.get().message(owner.getLogSubject(),TopicDeletePolicyMessages.DISCONNECTING()); // Close the consumer . this will cause autoDelete Queues to be purged owner.getConnectionModel(). closeSession(owner, AMQConstant.RESOURCE_ERROR, @@ -95,7 +95,7 @@ public class TopicDeletePolicy implements SlowConsumerPolicyPlugin // Actively delete non autoDelete queues if deletePersistent is set if (!q.isAutoDelete() && (_configuration != null && _configuration.deletePersistent())) { - CurrentActor.get().message(q.getLogSubject(), TopicDeletePolicyMessages.TDP_DELETING_QUEUE()); + CurrentActor.get().message(q.getLogSubject(), TopicDeletePolicyMessages.DELETING_QUEUE()); q.delete(); } -- cgit v1.2.1