QPID-2625 : Update GenerateLogMessages to probe the property file for 3-Digit LoggingClasses and use that as the basis for generation. Expose LogSubjects from Queue and Session.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@950635 13f79535-47bb-0310-9956-ffa450edef68

6 files changed, 49 insertions, 23 deletions

diff --git a/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java b/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
index 8a0e49f537..9d90694f55 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
@@ -1079,6 +1079,11 @@ public class AMQChannel implements SessionConfig, AMQSessionModel
         return String.valueOf(_session.getContextKey());
     }
 
+    public LogSubject getLogSubject()
+    {
+        return _logSubject;
+    }
+
     private class MessageDeliveryAction implements ServerTransaction.Action
     {
         private IncomingMessage _incommingMessage;
diff --git a/java/broker/src/main/java/org/apache/qpid/server/logging/messages/LogMessages.properties b/java/broker/src/main/java/org/apache/qpid/server/logging/messages/LogMessages.properties
index 7159c6b02c..9e19b44430 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/logging/messages/LogMessages.properties
+++ b/java/broker/src/main/java/org/apache/qpid/server/logging/messages/LogMessages.properties
@@ -207,7 +207,7 @@
 #
 #
 # Default File used for all non-defined locales.
-#Broker
+BRK=Broker
 # 0 - Version
 # 1 = Build
 BRK_STARTUP = BRK-1001 : Startup : Version: {0} Build: {1}
@@ -224,7 +224,8 @@ BRK_CONFIG = BRK-1006 : Using configuration : {0}
 # 0 - path
 BRK_LOG_CONFIG = BRK-1007 : Using logging configuration : {0}
 
-#ManagementConsole
+
+MNG=ManagementConsole
 MNG_STARTUP = MNG-1001 : Startup
 # 0 - Service
 # 1 - Port
@@ -240,12 +241,13 @@ MNG_OPEN = MNG-1007 : Open : User {0}
 MNG_CLOSE = MNG-1008 : Close
 
 
-#VirtualHost
+VHT=VirtualHost
+
 # 0 - name
 VHT_CREATED = VHT-1001 : Created : {0}
 VHT_CLOSED = VHT-1002 : Closed
 
-#MessageStore
+MST=MessageStore
 # 0 - name
 MST_CREATED = MST-1001 : Created : {0}
 # 0 - path
@@ -255,36 +257,36 @@ MST_RECOVERY_START = MST-1004 : Recovery Start
 MST_RECOVERED = MST-1005 : Recovered {0,number} messages
 MST_RECOVERY_COMPLETE = MST-1006 : Recovery Complete
 
-#ConfigStore
+CFG=ConfigStore
 # 0 - name
-CFG-1001 = CFG-1001 : Created : {0}
+CFG_1001 = CFG-1001 : Created : {0}
 # 0 - path
-CFG-1002 = CFG-1002 : Store location : {0}
-CFG-1003 = CFG-1003 : Closed
-CFG-1004 = CFG-1004 : Recovery Start
-CFG-1005 = CFG-1005 : Recovery Complete
+CFG_1002 = CFG-1002 : Store location : {0}
+CFG_1003 = CFG-1003 : Closed
+CFG_1004 = CFG-1004 : Recovery Start
+CFG_1005 = CFG-1005 : Recovery Complete
 
-#TransactionLog
+TXN=TransactionLog
 # 0 - name
-TXN-1001 = TXN-1001 : Created : {0}
+TXN_1001 = TXN-1001 : Created : {0}
 # 0 - path
-TXN-1002 = TXN-1002 : Store location : {0}
-TXN-1003 = TXN-1003 : Closed
+TXN_1002 = TXN-1002 : Store location : {0}
+TXN_1003 = TXN-1003 : Closed
 # 0 - queue name
-TXN-1004 = TXN-1004 : Recovery Start[ : {0}]
+TXN_1004 = TXN-1004 : Recovery Start[ : {0}]
 # 0 - count
 # 1 - queue count
-TXN-1005 = TXN-1005 : Recovered {0,number} messages for queue {1}
+TXN_1005 = TXN-1005 : Recovered {0,number} messages for queue {1}
 # 0 - queue name
-TXN-1006 = TXN-1006 : Recovery Complete[ : {0}]
+TXN_1006 = TXN-1006 : Recovery Complete[ : {0}]
 
-#Connection
+CON=Connection
 # 0 - Client id
 # 1 - Protocol Version
 CON_OPEN = CON-1001 : Open[ : Client ID : {0}][ : Protocol Version : {1}]
 CON_CLOSE = CON-1002 : Close
 
-#Channel
+CHN=Channel
 CHN_CREATE = CHN-1001 : Create
 # 0 - flow
 CHN_FLOW = CHN-1002 : Flow {0}
@@ -296,7 +298,7 @@ CHN_PREFETCH_SIZE = CHN-1004 : Prefetch Size (bytes) {0,number} : Count {1,numbe
 CHN_FLOW_ENFORCED = CHN-1005 : Flow Control Enforced (Queue {0})
 CHN_FLOW_REMOVED = CHN-1006 : Flow Control Removed
 
-#Queue
+QUE=Queue
 # 0 - owner
 # 1 - priority
 QUE_CREATED = QUE-1001 : Create :[ Owner: {0}][ AutoDelete][ Durable][ Transient][ Priority: {1,number,#}]
@@ -305,17 +307,17 @@ QUE_OVERFULL = QUE-1003 : Overfull : Size : {0,number} bytes, Capacity : {1,numb
 QUE_UNDERFULL = QUE-1004 : Underfull : Size : {0,number} bytes, Resume Capacity : {1,number}
 
 
-#Exchange
+EXH=Exchange
 # 0 - type
 # 1 - name
 EXH_CREATED = EXH-1001 : Create :[ Durable] Type: {0} Name: {1}
 EXH_DELETED = EXH-1002 : Deleted
 
-#Binding
+BND=Binding
 BND_CREATED = BND-1001 : Create[ : Arguments : {0}]
 BND_DELETED = BND-1002 : Deleted
 
-#Subscription
+SUB=Subscription
 SUB_CREATE = SUB-1001 : Create[ : Durable][ : Arguments : {0}]
 SUB_CLOSE = SUB-1002 : Close
 # 0 - The current subscription state
diff --git a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQSessionModel.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQSessionModel.java
index 31784fd034..a9b2354d75 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQSessionModel.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQSessionModel.java
@@ -20,6 +20,8 @@
  */
 package org.apache.qpid.server.protocol;
 
+import org.apache.qpid.server.logging.LogSubject;
+
 public interface AMQSessionModel
 {
     Object getID();
@@ -27,4 +29,6 @@ public interface AMQSessionModel
     AMQConnectionModel getConnectionModel();
 
     String getClientID();
+
+    LogSubject getLogSubject();
 }
diff --git a/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueue.java b/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueue.java
index 8b53257e88..3b60734a2e 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueue.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueue.java
@@ -24,6 +24,7 @@ import org.apache.qpid.AMQException;
 import org.apache.qpid.AMQSecurityException;
 import org.apache.qpid.framing.AMQShortString;
 import org.apache.qpid.server.AMQChannel;
+import org.apache.qpid.server.logging.LogSubject;
 import org.apache.qpid.server.protocol.AMQConnectionModel;
 import org.apache.qpid.server.protocol.AMQSessionModel;
 import org.apache.qpid.server.binding.Binding;
@@ -58,6 +59,8 @@ public interface AMQQueue extends Managable, Comparable<AMQQueue>, ExchangeRefer
 
     int getBindingCount();
 
+    LogSubject getLogSubject();
+
     public interface Context
     {
         QueueEntry getLastSeenEntry();
diff --git a/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java b/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
index 7e78fd0481..b3e0b4fba9 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
@@ -526,6 +526,11 @@ public class SimpleAMQQueue implements AMQQueue, Subscription.StateListener
         return getBindings().size();
     }
 
+    public LogSubject getLogSubject()
+    {
+        return _logSubject;
+    }
+
     // ------ Enqueue / Dequeue
     public void enqueue(ServerMessage message) throws AMQException
     {
diff --git a/java/broker/src/main/java/org/apache/qpid/server/transport/ServerSession.java b/java/broker/src/main/java/org/apache/qpid/server/transport/ServerSession.java
index bc7ba085fc..f79a43f330 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/transport/ServerSession.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/transport/ServerSession.java
@@ -28,6 +28,8 @@ import org.apache.qpid.server.configuration.ConfiguredObject;
 import org.apache.qpid.server.configuration.ConnectionConfig;
 import org.apache.qpid.server.configuration.SessionConfig;
 import org.apache.qpid.server.configuration.SessionConfigType;
+import org.apache.qpid.server.logging.LogSubject;
+import org.apache.qpid.server.logging.subjects.ConnectionLogSubject;
 import org.apache.qpid.server.message.ServerMessage;
 import org.apache.qpid.server.queue.AMQQueue;
 import org.apache.qpid.server.queue.BaseQueue;
@@ -571,4 +573,9 @@ public class ServerSession extends Session implements PrincipalHolder, SessionCo
         return getPrincipal().getName();
     }
 
+    public LogSubject getLogSubject()
+    {
+        return null;
+    }
+
 }