diff options
60 files changed, 847 insertions, 674 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 f0f65cc4c8..333c1b9cac 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 @@ -133,7 +133,7 @@ public class AMQChannel _actor = new AMQPChannelActor(this, session.getLogActor().getRootMessageLogger()); _logSubject = new ChannelLogSubject(this); - _actor.message(ChannelMessages.CHN_1001()); + _actor.message(ChannelMessages.CHN_CREATE()); _messageStore = messageStore; @@ -417,7 +417,7 @@ public class AMQChannel { _closing = closing; - CurrentActor.get().message(_logSubject, ChannelMessages.CHN_1003()); + CurrentActor.get().message(_logSubject, ChannelMessages.CHN_CLOSE()); } private void unsubscribeAllConsumers() throws AMQException @@ -737,7 +737,7 @@ public class AMQChannel // Log Flow Started before we start the subscriptions if (!suspended) { - _actor.message(_logSubject, ChannelMessages.CHN_1002("Started")); + _actor.message(_logSubject, ChannelMessages.CHN_FLOW("Started")); } @@ -788,7 +788,7 @@ public class AMQChannel // stopped. if (suspended) { - _actor.message(_logSubject, ChannelMessages.CHN_1002("Stopped")); + _actor.message(_logSubject, ChannelMessages.CHN_FLOW("Stopped")); } } @@ -904,7 +904,7 @@ public class AMQChannel public void setCredit(final long prefetchSize, final int prefetchCount) { - _actor.message(ChannelMessages.CHN_1004(prefetchSize, prefetchCount)); + _actor.message(ChannelMessages.CHN_PREFETCH_SIZE(prefetchSize, prefetchCount)); _creditManager.setCreditLimits(prefetchSize, prefetchCount); } @@ -1163,7 +1163,7 @@ public class AMQChannel if(_blocking.compareAndSet(false,true)) { - _actor.message(_logSubject, ChannelMessages.CHN_1005(queue.getName().toString())); + _actor.message(_logSubject, ChannelMessages.CHN_FLOW_ENFORCED(queue.getName().toString())); flow(false); } } @@ -1175,7 +1175,7 @@ public class AMQChannel { if(_blocking.compareAndSet(true,false)) { - _actor.message(_logSubject, ChannelMessages.CHN_1006()); + _actor.message(_logSubject, ChannelMessages.CHN_FLOW_REMOVED()); flow(true); } diff --git a/java/broker/src/main/java/org/apache/qpid/server/Main.java b/java/broker/src/main/java/org/apache/qpid/server/Main.java index 0a2bd6e8b0..845983857c 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/Main.java +++ b/java/broker/src/main/java/org/apache/qpid/server/Main.java @@ -266,7 +266,7 @@ public class Main } else { - CurrentActor.get().message(BrokerMessages.BRK_1006(configFile.getAbsolutePath())); + CurrentActor.get().message(BrokerMessages.BRK_CONFIG(configFile.getAbsolutePath())); } String logConfig = commandLine.getOptionValue("l"); @@ -417,7 +417,7 @@ public class Main serverConfig.getNetworkConfiguration(), null); ApplicationRegistry.getInstance().addAcceptor(new InetSocketAddress(bindAddress, port), new QpidAcceptor(driver,"TCP")); - CurrentActor.get().message(BrokerMessages.BRK_1002("TCP", port)); + CurrentActor.get().message(BrokerMessages.BRK_LISTENING("TCP", port)); } @@ -431,14 +431,14 @@ public class Main new AMQProtocolEngineFactory(), serverConfig.getNetworkConfiguration(), sslFactory); ApplicationRegistry.getInstance().addAcceptor(new InetSocketAddress(bindAddress, serverConfig.getSSLPort()), new QpidAcceptor(driver,"TCP")); - CurrentActor.get().message(BrokerMessages.BRK_1002("TCP/SSL", serverConfig.getSSLPort())); + CurrentActor.get().message(BrokerMessages.BRK_LISTENING("TCP/SSL", serverConfig.getSSLPort())); } //fixme qpid.AMQP should be using qpidproperties to get value _brokerLogger.info("Qpid Broker Ready :" + QpidProperties.getReleaseVersion() + " build: " + QpidProperties.getBuildVersion()); - CurrentActor.get().message(BrokerMessages.BRK_1004()); + CurrentActor.get().message(BrokerMessages.BRK_READY()); } finally @@ -558,7 +558,7 @@ public class Main { if (logConfigFile.exists() && logConfigFile.canRead()) { - CurrentActor.get().message(BrokerMessages.BRK_1007(logConfigFile.getAbsolutePath())); + CurrentActor.get().message(BrokerMessages.BRK_LOG_CONFIG(logConfigFile.getAbsolutePath())); System.out.println("Configuring logger using configuration file " + logConfigFile.getAbsolutePath()); if (logWatchTime > 0) { diff --git a/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java index 7983c62443..33af910f1a 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java +++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java @@ -185,7 +185,7 @@ public abstract class AbstractExchange implements Exchange, Managable _logSubject = new ExchangeLogSubject(this, this.getVirtualHost()); // Log Exchange creation - CurrentActor.get().message(ExchangeMessages.EXH_1001(String.valueOf(getType()), String.valueOf(name), durable)); + CurrentActor.get().message(ExchangeMessages.EXH_CREATED(String.valueOf(getType()), String.valueOf(name), durable)); } public abstract Logger getLogger(); @@ -216,7 +216,7 @@ public abstract class AbstractExchange implements Exchange, Managable _alternateExchange.removeReference(this); } - CurrentActor.get().message(_logSubject, ExchangeMessages.EXH_1002()); + CurrentActor.get().message(_logSubject, ExchangeMessages.EXH_DELETED()); } public String toString() diff --git a/java/broker/src/main/java/org/apache/qpid/server/logging/LogActor.java b/java/broker/src/main/java/org/apache/qpid/server/logging/LogActor.java index d5683b3c7b..18f03c2716 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/logging/LogActor.java +++ b/java/broker/src/main/java/org/apache/qpid/server/logging/LogActor.java @@ -57,4 +57,10 @@ public interface LogActor * @return the RootMessageLogger that is currently in use by this LogActor. */ RootMessageLogger getRootMessageLogger(); + + /** + * + * @return the String representing this LogActor + */ + public String getLogMessage(); }
\ No newline at end of file diff --git a/java/broker/src/main/java/org/apache/qpid/server/logging/actors/AMQPChannelActor.java b/java/broker/src/main/java/org/apache/qpid/server/logging/actors/AMQPChannelActor.java index d4d41bc1d4..a4f178eba7 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/logging/actors/AMQPChannelActor.java +++ b/java/broker/src/main/java/org/apache/qpid/server/logging/actors/AMQPChannelActor.java @@ -40,6 +40,7 @@ import java.text.MessageFormat; */ public class AMQPChannelActor extends AbstractActor { + private final String _logString; /** * Create a new ChannelActor @@ -74,5 +75,10 @@ public class AMQPChannelActor extends AbstractActor channel.getChannelId()) + "] "; } + + public String getLogMessage() + { + return _logString; + } } diff --git a/java/broker/src/main/java/org/apache/qpid/server/logging/actors/AMQPConnectionActor.java b/java/broker/src/main/java/org/apache/qpid/server/logging/actors/AMQPConnectionActor.java index d459fc0f06..20c416fed0 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/logging/actors/AMQPConnectionActor.java +++ b/java/broker/src/main/java/org/apache/qpid/server/logging/actors/AMQPConnectionActor.java @@ -54,6 +54,15 @@ public class AMQPConnectionActor extends AbstractActor */ public static final String USER_FORMAT = "con:{0}({1}@{2})"; + // The log string prefix for each message + private String _logString; + + // The Session this Actor is representing + private AMQProtocolSession _session; + + // Used to stop re-creating the _logString when we reach our final format + private boolean _upToDate = false; + public AMQPConnectionActor(AMQProtocolSession session, RootMessageLogger rootLogger) { super(rootLogger); @@ -61,55 +70,66 @@ public class AMQPConnectionActor extends AbstractActor _logString = "[" + MessageFormat.format(SOCKET_FORMAT, session.getSessionID(), session.getRemoteAddress()) - + "] "; + + _session = session; } /** - * Call when the connection has been authorized so that the logString - * can be updated with the new user identity. + * Update the LogString as the Connection process proceeds. + * + * When the Session has an authorized ID add that to the string. * - * @param session the authorized session + * When the Session then gains a Vhost add that to the string, at this point + * we can set upToDate = true as the _logString will not need to be updated + * from this point onwards. */ - public void connectionAuthorized(AMQProtocolSession session) + private void updateLogString() { - _logString = "[" + MessageFormat.format(USER_FORMAT, - session.getSessionID(), - session.getPrincipal().getName(), - session.getRemoteAddress()) - + "] "; + if (!_upToDate) + { + if (_session.getPrincipal() != null) + { + if (_session.getVirtualHost() != null) + { + /** + * LOG FORMAT used by the AMQPConnectorActor follows + * ConnectionLogSubject.CONNECTION_FORMAT : + * con:{0}({1}@{2}/{3}) + * + * Uses a MessageFormat call to insert the required values according to + * these indices: + * + * 0 - Connection ID + * 1 - User ID + * 2 - IP + * 3 - Virtualhost + */ + _logString = "[" + MessageFormat.format(ConnectionLogSubject.CONNECTION_FORMAT, + _session.getSessionID(), + _session.getPrincipal().getName(), + _session.getRemoteAddress(), + _session.getVirtualHost().getName()) + + "] "; + _upToDate = true; + } + else + { + _logString = "[" + MessageFormat.format(USER_FORMAT, + _session.getSessionID(), + _session.getPrincipal().getName(), + _session.getRemoteAddress()) + + "] "; + } + } + } } - /** - * Called once the user has been authenticated and they are now selecting - * the virtual host they wish to use. - * - * @param session the session that now has a virtualhost associated with it. - */ - public void virtualHostSelected(AMQProtocolSession session) + public String getLogMessage() { - - /** - * LOG FORMAT used by the AMQPConnectorActor follows - * ConnectionLogSubject.CONNECTION_FORMAT : - * con:{0}({1}@{2}/{3}) - * - * Uses a MessageFormat call to insert the requried values according to - * these indicies: - * - * 0 - Connection ID - * 1 - User ID - * 2 - IP - * 3 - Virtualhost - */ - _logString = "[" + MessageFormat.format(ConnectionLogSubject.CONNECTION_FORMAT, - session.getSessionID(), - session.getPrincipal().getName(), - session.getRemoteAddress(), - session.getVirtualHost().getName()) - + "] "; - + updateLogString(); + return _logString; } } diff --git a/java/broker/src/main/java/org/apache/qpid/server/logging/actors/AbstractActor.java b/java/broker/src/main/java/org/apache/qpid/server/logging/actors/AbstractActor.java index 0059a48c06..1fa2bd9600 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/logging/actors/AbstractActor.java +++ b/java/broker/src/main/java/org/apache/qpid/server/logging/actors/AbstractActor.java @@ -27,7 +27,6 @@ import org.apache.qpid.server.logging.RootMessageLogger; public abstract class AbstractActor implements LogActor { - protected String _logString; protected RootMessageLogger _rootLogger; public AbstractActor(RootMessageLogger rootLogger) @@ -43,7 +42,7 @@ public abstract class AbstractActor implements LogActor { if (_rootLogger.isMessageEnabled(this, subject)) { - _rootLogger.rawMessage(_logString + String.valueOf(subject) + message); + _rootLogger.rawMessage(getLogMessage() + String.valueOf(subject) + message); } } @@ -51,7 +50,7 @@ public abstract class AbstractActor implements LogActor { if (_rootLogger.isMessageEnabled(this)) { - _rootLogger.rawMessage(_logString + message); + _rootLogger.rawMessage(getLogMessage() + message); } } @@ -62,7 +61,9 @@ public abstract class AbstractActor implements LogActor public String toString() { - return _logString; + return getLogMessage(); } + abstract public String getLogMessage(); + } diff --git a/java/broker/src/main/java/org/apache/qpid/server/logging/actors/BrokerActor.java b/java/broker/src/main/java/org/apache/qpid/server/logging/actors/BrokerActor.java index 5d2762fd1d..9e77452228 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/logging/actors/BrokerActor.java +++ b/java/broker/src/main/java/org/apache/qpid/server/logging/actors/BrokerActor.java @@ -24,6 +24,7 @@ import org.apache.qpid.server.logging.RootMessageLogger; public class BrokerActor extends AbstractActor { + private final String _logString; /** * Create a new BrokerActor @@ -44,4 +45,9 @@ public class BrokerActor extends AbstractActor _logString = "[Broker(" + name + ")] "; } + public String getLogMessage() + { + return _logString; + } + } diff --git a/java/broker/src/main/java/org/apache/qpid/server/logging/actors/ManagementActor.java b/java/broker/src/main/java/org/apache/qpid/server/logging/actors/ManagementActor.java index 85fbb8f1ac..2825fa1b75 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/logging/actors/ManagementActor.java +++ b/java/broker/src/main/java/org/apache/qpid/server/logging/actors/ManagementActor.java @@ -53,11 +53,15 @@ public class ManagementActor extends AbstractActor */ public static final String MANAGEMENT_FORMAT = "mng:{0}({1})"; + /** + * The logString to be used for logging + */ + private String _logString; + /** @param rootLogger The RootLogger to use for this Actor */ public ManagementActor(RootMessageLogger rootLogger) { super(rootLogger); - } private void updateLogString() @@ -101,18 +105,10 @@ public class ManagementActor extends AbstractActor } } - @Override - public void message(LogSubject subject, LogMessage message) - { - updateLogString(); - super.message(subject, message); - } - - @Override - public void message(LogMessage message) + public String getLogMessage() { updateLogString(); - super.message(message); + return _logString; } } diff --git a/java/broker/src/main/java/org/apache/qpid/server/logging/actors/QueueActor.java b/java/broker/src/main/java/org/apache/qpid/server/logging/actors/QueueActor.java index acac447ff6..e62e711514 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/logging/actors/QueueActor.java +++ b/java/broker/src/main/java/org/apache/qpid/server/logging/actors/QueueActor.java @@ -32,6 +32,7 @@ import java.text.MessageFormat; */ public class QueueActor extends AbstractActor { + private final String _logString; /** * Create an QueueLogSubject that Logs in the following format. @@ -46,7 +47,11 @@ public class QueueActor extends AbstractActor _logString = "[" + MessageFormat.format(QueueLogSubject.LOG_FORMAT, queue.getVirtualHost().getName(), queue.getName()) + "] "; + } + public String getLogMessage() + { + return _logString; } }
\ No newline at end of file diff --git a/java/broker/src/main/java/org/apache/qpid/server/logging/actors/SubscriptionActor.java b/java/broker/src/main/java/org/apache/qpid/server/logging/actors/SubscriptionActor.java index ab33a29eac..63892e6353 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/logging/actors/SubscriptionActor.java +++ b/java/broker/src/main/java/org/apache/qpid/server/logging/actors/SubscriptionActor.java @@ -21,6 +21,8 @@ package org.apache.qpid.server.logging.actors; import org.apache.qpid.server.logging.RootMessageLogger; +import org.apache.qpid.server.logging.subjects.QueueLogSubject; +import org.apache.qpid.server.logging.subjects.SubscriptionLogSubject; import org.apache.qpid.server.subscription.Subscription; import java.text.MessageFormat; @@ -28,15 +30,21 @@ import java.text.MessageFormat; public class SubscriptionActor extends AbstractActor { public static String SUBSCRIBER_FORMAT = "sub:{0}(vh({1})/qu({2}))"; + private final String _logString; public SubscriptionActor(RootMessageLogger logger, Subscription subscription) { super(logger); - _logString = "[" + MessageFormat.format(SUBSCRIBER_FORMAT, + _logString = "[" + MessageFormat.format(SubscriptionLogSubject.SUBSCRIPTION_FORMAT, subscription.getSubscriptionID(), subscription.getQueue().getVirtualHost().getName(), subscription.getQueue().getName()) + "] "; } + + public String getLogMessage() + { + return _logString; + } } 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 1a2cb7251c..7159c6b02c 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 @@ -17,116 +17,307 @@ # under the License. # # Default File used for all non-defined locales. +# +# LogMessages used within the Java Broker as originally defined on the wiki: +# http://cwiki.apache.org/confluence/display/qpid/Status+Update+Design#StatusUpdateDesign-InitialStatusMessages +# +# Technical Notes: +# This is a standard Java Properties file so white space is respected at the +# end of the lines. This file is processed in a number of ways. +# 1) ResourceBundle +# This file is loaded through a ResourceBundle named LogMessages. the en_US +# addition to the file is the localisation. Additional localisations can be +# provided and will automatically be selected based on the <locale> value in +# the config.xml. The default is en_US. +# +# 2) MessasgeFormat +# Each entry is prepared with the Java Core MessageFormat methods. Therefore +# most functionality you can do via MessageFormat can be done here: +# +# http://java.sun.com/javase/6/docs/api/java/text/MessageFormat.html +# +# The cavet here is that only default String and number FormatTypes can be used. +# This is due to the processing described in 3 below. If support for date, time +# or choice is requried then the GenerateLogMessages class should be updated to +# provide support. +# +# Format Note: +# As mentioned earlier white space in this file is very important. One thing +# in particular to note is the way MessageFormat peforms its replacements. +# The replacement text will totally replace the {xxx} section so there will be +# no addtion of white space or removal e.g. +# MSG = Text----{0}---- +# When given parameter 'Hello' result in text: +# Text----Hello---- +# +# For simple arguments this is expected however when using Style formats then +# it can be a little unexepcted. In particular a common pattern is used for +# number replacements : {0,number,#}. This is used in the Broker to display an +# Integer simply as the Integer with no formating. e.g new Integer(1234567) +# becomes the String "1234567" which is can be contrasted with the pattern +# without a style format field : {0,number} which becomes string "1,234,567". +# +# What you may not expect is that {0,number, #} would produce the String " 1234567" +# note the space after the ',' here /\ has resulted in a space /\ in +# the output. +# +# More details on the SubformatPattern can be found on the API link above. +# +# 3) GenerateLogMessage/Velocity Macro +# This is the first and final stage of processing that this file goes through. +# 1) Class Generation: +# The GenerateLogMessage processes this file and uses the velocity Macro +# to create classes with static methods to perform the logging and give us +# compile time validation. +# +# 2) Property Processing: +# During the class generation the message properties ({x}) are identified +# and used to create the method signature. +# +# 3) Option Processing: +# The Classes perform final formatting of the messages at runtime based on +# optional parameters that are defined within the message. Optional +# paramters are enclosed in square brackets e.g. [optional]. +# +# To provide fixed log messages as required by the Technical Specification: +# http://cwiki.apache.org/confluence/display/qpid/Operational+Logging+-+Status+Update+-+Technical+Specification#OperationalLogging-StatusUpdate-TechnicalSpecification-Howtoprovidefixedlogmessages +# +# This file is processed by Velocity to create a number of classes that contain +# static methods that provide LogMessages in the code to provide compile time +# validation. +# +# For details of what processing is done see GenerateLogMessages. +# +# What a localiser or developer need know is the following: +# +# The Property structure is important is it defines how the class and methods +# will be built. +# +# Class Generation: +# ================= +# +# Each class of messages will be split in to their own <Class>Messages.java +# Currently the following classes are created and are populated with the +# messages that bear their 3-digit type identifier: +# +# Class | Type +# ---------------------|-------- +# Broker | BKR +# ManagementConsole | MNG +# VirtualHost | VHT +# MessageStore | MST +# ConfigStore | CFG +# TransactionLog | TXN +# Connection | CON +# Channel | CHN +# Queue | QUE +# Exchange | EXH +# Binding | BND +# Subscription | SUB +# +# Property Format +# =============== +# The property format MUST adhere to the follow format to make it easier to +# use the logging API as a developer but also so that operations staff can +# easily locate log messages in the output. +# +# The property file should contain entries in the following format +# +# <Log Identifier, developer focused> = <Log Identifier, Operate focus> : <Log Message> +# +# eg: +# BRK_SHUTTING_DOWN = BRK-1003 : Shuting down : {0} port {1,number,#} +# +# Note: the developer focused identifier will become a method name so only a +# valid method name should be used. Currently only '-' are converted to '_'. +# +# That said properties generate the logging code at build time so any error +# can be easily identified. +# +# Property Processing: +# ==================== +# +# Each property is then processed by the GenerateLogMessages class to identify +# The number and type of parameters, {x} entries. Parameters are defaulted to +# String types but the use of FormatType number (e.g.{0,number}) will result +# in a Number type being used. These parameters are then used to build the +# method parameter list. e.g: +# Property: +# BRK_SHUTTING_DOWN = BRK-1003 : Shuting down : {0} port {1,number,#} +# becomes Method: +# public static LogMessage BRK_SHUTTING_DOWN(String param1, Number param2) +# +# This improves our compile time validation of log message content and +# ensures that change in the message format does not accidentally cause +# erroneous messages. +# +# Option Processing: +# ==================== +# +# Options are identified in the log message as being surrounded by square +# brackets ([ ]). These optional values can themselves contain paramters +# however nesting of options is not permitted. Identification is performed on +# first matchings so give the message: +# Msg = Log Message [option1] [option2] +# Two options will be identifed and enabled to select text 'option1 and +# 'option2'. +# +# The nesting of a options is not supported and will provide +# unexpected results. e.g. Using Message: +# Msg = Log Message [option1 [sub-option2]] +# +# The options will be 'option1 [sub-option2' and 'sub-option2'. The first +# option includes the second option as the nesting is not detected. +# +# The detected options are presented in the method signature as boolean options +# numerically identified by their position in the message. e.g. +# Property: +# CON-1001 = Open : Client ID {0} [: Protocol Version : {1}] +# becomes Method: +# public static LogMessage CON_1001(String param1, String param2, boolean opt1) +# +# The value of 'opt1' will show/hide the option in the message. Note that +# 'param2' is still required however a null value can be used if the optional +# section is not desired. +# +# Again here the importance of white space needs to be highlighted. +# Looking at the QUE-1001 message as an example. The first thought on how this +# would look would be as follows: +# QUE-1001 = Create : Owner: {0} [AutoDelete] [Durable] [Transient] [Priority: {1,number,#}] +# Each option is correctly defined so the text that is defined will appear when +# selected. e.g. 'AutoDelete'. However, what may not be immediately apparent is +# the white space. Using the above definition of QUE-1001 if we were to print +# the message with only the Priority option displayed it would appear as this: +# "Create : Owner: guest Priority: 1" +# Note the spaces here /\ This is because only the text between the brackets +# has been removed. +# +# Each option needs to include white space to correctly format the message. So +# the correct definition of QUE-1001 is as follows: +# QUE-1001 = Create : Owner: {0}[ AutoDelete][ Durable][ Transient][ Priority: {1,number,#}] +# Note that white space is included with each option and there is no extra +# white space between the options. As a result the output with just Priority +# enabled is as follows: +# "Create : Owner: guest Priority: 1" +# +# The final processing that is done in the generation is the conversion of the +# property name. As a '-' is an illegal character in the method name it is +# converted to '_' This processing gives the final method signature as follows: +# <Class>Message.<Type>_<Number>(<parmaters>,<options>) +# +# +# Default File used for all non-defined locales. #Broker # 0 - Version # 1 = Build -BRK-1001 = Startup : Version: {0} Build: {1} +BRK_STARTUP = BRK-1001 : Startup : Version: {0} Build: {1} # 0 - Transport # 1 - Port -BRK-1002 = Starting : Listening on {0} port {1,number,#} +BRK_LISTENING = BRK-1002 : Starting : Listening on {0} port {1,number,#} # 0 - Transport # 1 - Port -BRK-1003 = Shuting down : {0} port {1,number,#} -BRK-1004 = Ready -BRK-1005 = Stopped +BRK_SHUTTING_DOWN = BRK-1003 : Shuting down : {0} port {1,number,#} +BRK_READY = BRK-1004 : Ready +BRK_STOPPED = BRK-1005 : Stopped # 0 - path -BRK-1006 = Using configuration : {0} +BRK_CONFIG = BRK-1006 : Using configuration : {0} # 0 - path -BRK-1007 = Using logging configuration : {0} +BRK_LOG_CONFIG = BRK-1007 : Using logging configuration : {0} #ManagementConsole -MNG-1001 = Startup +MNG_STARTUP = MNG-1001 : Startup # 0 - Service # 1 - Port -MNG-1002 = Starting : {0} : Listening on port {1,number,#} +MNG_LISTENING = MNG-1002 : Starting : {0} : Listening on port {1,number,#} # 0 - Service # 1 - Port -MNG-1003 = Shuting down : {0} : port {1,number,#} -MNG-1004 = Ready -MNG-1005 = Stopped +MNG_SHUTTING_DOWN = MNG-1003 : Shuting down : {0} : port {1,number,#} +MNG_READY = MNG-1004 : Ready +MNG_STOPPED = MNG-1005 : Stopped # 0 - Path -MNG-1006 = Using SSL Keystore : {0} -MNG-1007 = Open : User {0} -MNG-1008 = Close +MNG_SSL_KEYSTORE = MNG-1006 : Using SSL Keystore : {0} +MNG_OPEN = MNG-1007 : Open : User {0} +MNG_CLOSE = MNG-1008 : Close #VirtualHost # 0 - name -VHT-1001 = Created : {0} -VHT-1002 = Closed +VHT_CREATED = VHT-1001 : Created : {0} +VHT_CLOSED = VHT-1002 : Closed #MessageStore # 0 - name -MST-1001 = Created : {0} +MST_CREATED = MST-1001 : Created : {0} # 0 - path -MST-1002 = Store location : {0} -MST-1003 = Closed -MST-1004 = Recovery Start -MST-1005 = Recovered {0,number} messages -MST-1006 = Recovery Complete +MST_STORE_LOCATION = MST-1002 : Store location : {0} +MST_CLOSED = MST-1003 : Closed +MST_RECOVERY_START = MST-1004 : Recovery Start +MST_RECOVERED = MST-1005 : Recovered {0,number} messages +MST_RECOVERY_COMPLETE = MST-1006 : Recovery Complete #ConfigStore # 0 - name -CFG-1001 = Created : {0} +CFG-1001 = CFG-1001 : Created : {0} # 0 - path -CFG-1002 = Store location : {0} -CFG-1003 = Closed -CFG-1004 = Recovery Start -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 # 0 - name -TXN-1001 = Created : {0} +TXN-1001 = TXN-1001 : Created : {0} # 0 - path -TXN-1002 = Store location : {0} -TXN-1003 = Closed +TXN-1002 = TXN-1002 : Store location : {0} +TXN-1003 = TXN-1003 : Closed # 0 - queue name -TXN-1004 = Recovery Start[ : {0}] +TXN-1004 = TXN-1004 : Recovery Start[ : {0}] # 0 - count # 1 - queue count -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 = Recovery Complete[ : {0}] +TXN-1006 = TXN-1006 : Recovery Complete[ : {0}] #Connection # 0 - Client id # 1 - Protocol Version -CON-1001 = Open[ : Client ID : {0}][ : Protocol Version : {1}] -CON-1002 = Close +CON_OPEN = CON-1001 : Open[ : Client ID : {0}][ : Protocol Version : {1}] +CON_CLOSE = CON-1002 : Close #Channel -CHN-1001 = Create +CHN_CREATE = CHN-1001 : Create # 0 - flow -CHN-1002 = Flow {0} -CHN-1003 = Close +CHN_FLOW = CHN-1002 : Flow {0} +CHN_CLOSE = CHN-1003 : Close # 0 - bytes allowed in prefetch # 1 - number of messagse. -CHN-1004 = Prefetch Size (bytes) {0,number} : Count {1,number} +CHN_PREFETCH_SIZE = CHN-1004 : Prefetch Size (bytes) {0,number} : Count {1,number} # 0 - queue causing flow control -CHN-1005 = Flow Control Enforced (Queue {0}) -CHN-1006 = Flow Control Removed +CHN_FLOW_ENFORCED = CHN-1005 : Flow Control Enforced (Queue {0}) +CHN_FLOW_REMOVED = CHN-1006 : Flow Control Removed #Queue # 0 - owner # 1 - priority -QUE-1001 = Create :[ Owner: {0}][ AutoDelete][ Durable][ Transient][ Priority: {1,number,#}] -QUE-1002 = Deleted -QUE-1003 = Overfull : Size : {0,number} bytes, Capacity : {1,number} -QUE-1004 = Underfull : Size : {0,number} bytes, Resume Capacity : {1,number} +QUE_CREATED = QUE-1001 : Create :[ Owner: {0}][ AutoDelete][ Durable][ Transient][ Priority: {1,number,#}] +QUE_DELETED = QUE-1002 : Deleted +QUE_OVERFULL = QUE-1003 : Overfull : Size : {0,number} bytes, Capacity : {1,number} +QUE_UNDERFULL = QUE-1004 : Underfull : Size : {0,number} bytes, Resume Capacity : {1,number} #Exchange # 0 - type # 1 - name -EXH-1001 = Create :[ Durable] Type: {0} Name: {1} -EXH-1002 = Deleted +EXH_CREATED = EXH-1001 : Create :[ Durable] Type: {0} Name: {1} +EXH_DELETED = EXH-1002 : Deleted #Binding -BND-1001 = Create[ : Arguments : {0}] -BND-1002 = Deleted +BND_CREATED = BND-1001 : Create[ : Arguments : {0}] +BND_DELETED = BND-1002 : Deleted #Subscription -SUB-1001 = Create[ : Durable][ : Arguments : {0}] -SUB-1002 = Close +SUB_CREATE = SUB-1001 : Create[ : Durable][ : Arguments : {0}] +SUB_CLOSE = SUB-1002 : Close # 0 - The current subscription state -SUB-1003 = State : {0} +SUB_STATE = SUB-1003 : State : {0} + diff --git a/java/broker/src/main/java/org/apache/qpid/server/logging/messages/LogMessages_en_US.properties b/java/broker/src/main/java/org/apache/qpid/server/logging/messages/LogMessages_en_US.properties deleted file mode 100644 index 1a2cb7251c..0000000000 --- a/java/broker/src/main/java/org/apache/qpid/server/logging/messages/LogMessages_en_US.properties +++ /dev/null @@ -1,132 +0,0 @@ -# -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you under the Apache License, Version 2.0 (the -# "License"); you may not use this file except in compliance -# with the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, -# software distributed under the License is distributed on an -# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -# KIND, either express or implied. See the License for the -# specific language governing permissions and limitations -# under the License. -# -# Default File used for all non-defined locales. -#Broker -# 0 - Version -# 1 = Build -BRK-1001 = Startup : Version: {0} Build: {1} -# 0 - Transport -# 1 - Port -BRK-1002 = Starting : Listening on {0} port {1,number,#} -# 0 - Transport -# 1 - Port -BRK-1003 = Shuting down : {0} port {1,number,#} -BRK-1004 = Ready -BRK-1005 = Stopped -# 0 - path -BRK-1006 = Using configuration : {0} -# 0 - path -BRK-1007 = Using logging configuration : {0} - -#ManagementConsole -MNG-1001 = Startup -# 0 - Service -# 1 - Port -MNG-1002 = Starting : {0} : Listening on port {1,number,#} -# 0 - Service -# 1 - Port -MNG-1003 = Shuting down : {0} : port {1,number,#} -MNG-1004 = Ready -MNG-1005 = Stopped -# 0 - Path -MNG-1006 = Using SSL Keystore : {0} -MNG-1007 = Open : User {0} -MNG-1008 = Close - - -#VirtualHost -# 0 - name -VHT-1001 = Created : {0} -VHT-1002 = Closed - -#MessageStore -# 0 - name -MST-1001 = Created : {0} -# 0 - path -MST-1002 = Store location : {0} -MST-1003 = Closed -MST-1004 = Recovery Start -MST-1005 = Recovered {0,number} messages -MST-1006 = Recovery Complete - -#ConfigStore -# 0 - name -CFG-1001 = Created : {0} -# 0 - path -CFG-1002 = Store location : {0} -CFG-1003 = Closed -CFG-1004 = Recovery Start -CFG-1005 = Recovery Complete - -#TransactionLog -# 0 - name -TXN-1001 = Created : {0} -# 0 - path -TXN-1002 = Store location : {0} -TXN-1003 = Closed -# 0 - queue name -TXN-1004 = Recovery Start[ : {0}] -# 0 - count -# 1 - queue count -TXN-1005 = Recovered {0,number} messages for queue {1} -# 0 - queue name -TXN-1006 = Recovery Complete[ : {0}] - -#Connection -# 0 - Client id -# 1 - Protocol Version -CON-1001 = Open[ : Client ID : {0}][ : Protocol Version : {1}] -CON-1002 = Close - -#Channel -CHN-1001 = Create -# 0 - flow -CHN-1002 = Flow {0} -CHN-1003 = Close -# 0 - bytes allowed in prefetch -# 1 - number of messagse. -CHN-1004 = Prefetch Size (bytes) {0,number} : Count {1,number} -# 0 - queue causing flow control -CHN-1005 = Flow Control Enforced (Queue {0}) -CHN-1006 = Flow Control Removed - -#Queue -# 0 - owner -# 1 - priority -QUE-1001 = Create :[ Owner: {0}][ AutoDelete][ Durable][ Transient][ Priority: {1,number,#}] -QUE-1002 = Deleted -QUE-1003 = Overfull : Size : {0,number} bytes, Capacity : {1,number} -QUE-1004 = Underfull : Size : {0,number} bytes, Resume Capacity : {1,number} - - -#Exchange -# 0 - type -# 1 - name -EXH-1001 = Create :[ Durable] Type: {0} Name: {1} -EXH-1002 = Deleted - -#Binding -BND-1001 = Create[ : Arguments : {0}] -BND-1002 = Deleted - -#Subscription -SUB-1001 = Create[ : Durable][ : Arguments : {0}] -SUB-1002 = Close -# 0 - The current subscription state -SUB-1003 = State : {0} diff --git a/java/broker/src/main/java/org/apache/qpid/server/logging/subjects/SubscriptionLogSubject.java b/java/broker/src/main/java/org/apache/qpid/server/logging/subjects/SubscriptionLogSubject.java index b68ef2e9a9..c842da4db0 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/logging/subjects/SubscriptionLogSubject.java +++ b/java/broker/src/main/java/org/apache/qpid/server/logging/subjects/SubscriptionLogSubject.java @@ -33,7 +33,7 @@ public class SubscriptionLogSubject extends AbstractLogSubject * 0 - Subscription ID * 1 - queue name */ - protected static String BINDING_FORMAT = "sub:{0}(qu({1}))"; + public static String SUBSCRIPTION_FORMAT = "sub:{0}(vh(/{1})/qu({2}))"; /** * Create an QueueLogSubject that Logs in the following format. @@ -42,8 +42,8 @@ public class SubscriptionLogSubject extends AbstractLogSubject */ public SubscriptionLogSubject(Subscription subscription) { - - setLogStringWithFormat(BINDING_FORMAT, subscription.getSubscriptionID(), + setLogStringWithFormat(SUBSCRIPTION_FORMAT, subscription.getSubscriptionID(), + subscription.getQueue().getVirtualHost().getName(), subscription.getQueue().getName()); } } diff --git a/java/broker/src/main/java/org/apache/qpid/server/management/JMXManagedObjectRegistry.java b/java/broker/src/main/java/org/apache/qpid/server/management/JMXManagedObjectRegistry.java index 92657d7f3c..048551010e 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/management/JMXManagedObjectRegistry.java +++ b/java/broker/src/main/java/org/apache/qpid/server/management/JMXManagedObjectRegistry.java @@ -100,7 +100,7 @@ public class JMXManagedObjectRegistry implements ManagedObjectRegistry public void start() throws IOException, ConfigurationException { - CurrentActor.get().message(ManagementConsoleMessages.MNG_1001()); + CurrentActor.get().message(ManagementConsoleMessages.MNG_STARTUP()); //check if system properties are set to use the JVM's out-of-the-box JMXAgent if (areOutOfTheBoxJMXOptionsSet()) @@ -171,7 +171,7 @@ public class JMXManagedObjectRegistry implements ManagedObjectRegistry _log.info("JMX ConnectorServer using SSL keystore file " + ksf.getAbsolutePath()); _startupLog.info("JMX ConnectorServer using SSL keystore file " + ksf.getAbsolutePath()); - CurrentActor.get().message(ManagementConsoleMessages.MNG_1006(ksf.getAbsolutePath())); + CurrentActor.get().message(ManagementConsoleMessages.MNG_SSL_KEYSTORE(ksf.getAbsolutePath())); } //check the key store password is set @@ -199,8 +199,8 @@ public class JMXManagedObjectRegistry implements ManagedObjectRegistry _startupLog.warn("Starting JMX ConnectorServer on port '"+ port + "' (+" + (port +PORT_EXPORT_OFFSET) + ") with SSL"); - CurrentActor.get().message(ManagementConsoleMessages.MNG_1002("SSL RMI Registry", port)); - CurrentActor.get().message(ManagementConsoleMessages.MNG_1002("SSL RMI ConnectorServer", port + PORT_EXPORT_OFFSET)); + CurrentActor.get().message(ManagementConsoleMessages.MNG_LISTENING("SSL RMI Registry", port)); + CurrentActor.get().message(ManagementConsoleMessages.MNG_LISTENING("SSL RMI ConnectorServer", port + PORT_EXPORT_OFFSET)); } else @@ -211,8 +211,8 @@ public class JMXManagedObjectRegistry implements ManagedObjectRegistry _log.warn("Starting JMX ConnectorServer on port '" + port + "' (+" + (port +PORT_EXPORT_OFFSET) + ")"); _startupLog.warn("Starting JMX ConnectorServer on port '" + port + "' (+" + (port +PORT_EXPORT_OFFSET) + ")"); - CurrentActor.get().message(ManagementConsoleMessages.MNG_1002("RMI Registry", port)); - CurrentActor.get().message(ManagementConsoleMessages.MNG_1002("RMI ConnectorServer", port + PORT_EXPORT_OFFSET)); + CurrentActor.get().message(ManagementConsoleMessages.MNG_LISTENING("RMI Registry", port)); + CurrentActor.get().message(ManagementConsoleMessages.MNG_LISTENING("RMI ConnectorServer", port + PORT_EXPORT_OFFSET)); } //add a JMXAuthenticator implementation the env map to authenticate the RMI based JMX connector server @@ -301,7 +301,7 @@ public class JMXManagedObjectRegistry implements ManagedObjectRegistry _cs.start(); - CurrentActor.get().message(ManagementConsoleMessages.MNG_1004()); + CurrentActor.get().message(ManagementConsoleMessages.MNG_READY()); } /* @@ -389,8 +389,8 @@ public class JMXManagedObjectRegistry implements ManagedObjectRegistry try { _cs.stop(); - CurrentActor.get().message(ManagementConsoleMessages.MNG_1003("RMI Registry", _cs.getAddress().getPort() - PORT_EXPORT_OFFSET)); - CurrentActor.get().message(ManagementConsoleMessages.MNG_1003("RMI ConnectorServer", _cs.getAddress().getPort())); + CurrentActor.get().message(ManagementConsoleMessages.MNG_SHUTTING_DOWN("RMI Registry", _cs.getAddress().getPort() - PORT_EXPORT_OFFSET)); + CurrentActor.get().message(ManagementConsoleMessages.MNG_SHUTTING_DOWN("RMI ConnectorServer", _cs.getAddress().getPort())); } catch (IOException e) { @@ -421,7 +421,7 @@ public class JMXManagedObjectRegistry implements ManagedObjectRegistry } } - CurrentActor.get().message(ManagementConsoleMessages.MNG_1005()); + CurrentActor.get().message(ManagementConsoleMessages.MNG_STOPPED()); } } diff --git a/java/broker/src/main/java/org/apache/qpid/server/management/MBeanInvocationHandlerImpl.java b/java/broker/src/main/java/org/apache/qpid/server/management/MBeanInvocationHandlerImpl.java index 20410ba5ce..0ee5763d91 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/management/MBeanInvocationHandlerImpl.java +++ b/java/broker/src/main/java/org/apache/qpid/server/management/MBeanInvocationHandlerImpl.java @@ -26,8 +26,6 @@ import org.apache.qpid.management.common.mbeans.UserManagement; import org.apache.qpid.server.logging.actors.CurrentActor; import org.apache.qpid.server.logging.actors.ManagementActor; import org.apache.qpid.server.logging.messages.ManagementConsoleMessages; -import org.apache.qpid.server.logging.messages.ConnectionMessages; -import org.apache.qpid.server.logging.LogActor; import org.apache.log4j.Logger; import javax.management.remote.MBeanServerForwarder; @@ -47,7 +45,6 @@ import java.lang.reflect.Method; import java.security.AccessController; import java.security.Principal; import java.security.AccessControlContext; -import java.util.ArrayList; import java.util.HashSet; import java.util.Set; import java.util.Properties; @@ -276,12 +273,12 @@ public class MBeanInvocationHandlerImpl implements InvocationHandler, Notificati if (notification.getType().equals(JMXConnectionNotification.OPENED)) { - _logActor.message(ManagementConsoleMessages.MNG_1007(user)); + _logActor.message(ManagementConsoleMessages.MNG_OPEN(user)); } else if (notification.getType().equals(JMXConnectionNotification.CLOSED) || notification.getType().equals(JMXConnectionNotification.FAILED)) { - _logActor.message(ManagementConsoleMessages.MNG_1008()); + _logActor.message(ManagementConsoleMessages.MNG_CLOSE()); } } } diff --git a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolEngine.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolEngine.java index 0824d12416..0a1fdb686f 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolEngine.java +++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolEngine.java @@ -178,7 +178,7 @@ public class AMQProtocolEngine implements ProtocolEngine, Managable, AMQProtocol _writeJob = new Job(_poolReference, Job.MAX_JOB_EVENTS, false); _actor = new AMQPConnectionActor(this, virtualHostRegistry.getApplicationRegistry().getRootMessageLogger()); - _actor.message(ConnectionMessages.CON_1001(null, null, false, false)); + _actor.message(ConnectionMessages.CON_OPEN(null, null, false, false)); } @@ -329,7 +329,7 @@ public class AMQProtocolEngine implements ProtocolEngine, Managable, AMQProtocol try { // Log incomming protocol negotiation request - _actor.message(ConnectionMessages.CON_1001(null, pi._protocolMajor + "-" + pi._protocolMinor, false, true)); + _actor.message(ConnectionMessages.CON_OPEN(null, pi._protocolMajor + "-" + pi._protocolMinor, false, true)); ProtocolVersion pv = pi.checkVersion(); // Fails if not correct @@ -720,7 +720,7 @@ public class AMQProtocolEngine implements ProtocolEngine, Managable, AMQProtocol notifyAll(); } _poolReference.releaseExecutorService(); - CurrentActor.get().message(_logSubject, ConnectionMessages.CON_1002()); + CurrentActor.get().message(_logSubject, ConnectionMessages.CON_CLOSE()); } } else @@ -840,7 +840,7 @@ public class AMQProtocolEngine implements ProtocolEngine, Managable, AMQProtocol setContextKey(new AMQShortString(clientID)); // Log the Opening of the connection for this client - _actor.message(ConnectionMessages.CON_1001(clientID, _protocolVersion.toString(), true, true)); + _actor.message(ConnectionMessages.CON_OPEN(clientID, _protocolVersion.toString(), true, true)); } if (_clientProperties.getString(ClientProperties.version.toString()) != null) @@ -898,7 +898,6 @@ public class AMQProtocolEngine implements ProtocolEngine, Managable, AMQProtocol { _virtualHost = virtualHost; - _actor.virtualHostSelected(this); _logSubject = new ConnectionLogSubject(this); _virtualHost.getConnectionRegistry().registerConnection(this); @@ -932,9 +931,6 @@ public class AMQProtocolEngine implements ProtocolEngine, Managable, AMQProtocol public void setAuthorizedID(Principal authorizedID) { _authorizedID = authorizedID; - - // Let the actor know that this connection is now Authorized - _actor.connectionAuthorized(this); } public Principal getAuthorizedID() diff --git a/java/broker/src/main/java/org/apache/qpid/server/queue/ExchangeBinding.java b/java/broker/src/main/java/org/apache/qpid/server/queue/ExchangeBinding.java index 6e87cfbb76..2fd8e32fcd 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/queue/ExchangeBinding.java +++ b/java/broker/src/main/java/org/apache/qpid/server/queue/ExchangeBinding.java @@ -45,7 +45,7 @@ public class ExchangeBinding _arguments = arguments == null ? EMPTY_ARGUMENTS : arguments; _logSubject = new BindingLogSubject(routingKey,exchange,queue); - CurrentActor.get().message(_logSubject, BindingMessages.BND_1001(String.valueOf(_arguments), arguments != null)); + CurrentActor.get().message(_logSubject, BindingMessages.BND_CREATED(String.valueOf(_arguments), arguments != null)); } @@ -54,7 +54,7 @@ public class ExchangeBinding { _exchange.deregisterQueue(_routingKey, queue, _arguments); - CurrentActor.get().message(_logSubject, BindingMessages.BND_1002()); + CurrentActor.get().message(_logSubject, BindingMessages.BND_DELETED()); } public Exchange getExchange() 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 77a6fb9328..d7d0414936 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 @@ -200,7 +200,7 @@ public class SimpleAMQQueue implements AMQQueue, Subscription.StateListener // Log the creation of this Queue. // The priorities display is toggled on if we set priorities > 0 CurrentActor.get().message(_logSubject, - QueueMessages.QUE_1001(String.valueOf(_owner), + QueueMessages.QUE_CREATED(String.valueOf(_owner), priorities, _owner != null, autoDelete, @@ -1297,7 +1297,7 @@ public class SimpleAMQQueue implements AMQQueue, Subscription.StateListener stop(); //Log Queue Deletion - CurrentActor.get().message(_logSubject, QueueMessages.QUE_1002()); + CurrentActor.get().message(_logSubject, QueueMessages.QUE_DELETED()); } return getMessageCount(); @@ -1320,7 +1320,7 @@ public class SimpleAMQQueue implements AMQQueue, Subscription.StateListener { _overfull.set(true); //Overfull log message - _logActor.message(_logSubject, QueueMessages.QUE_1003(_atomicQueueSize.get(), _capacity)); + _logActor.message(_logSubject, QueueMessages.QUE_OVERFULL(_atomicQueueSize.get(), _capacity)); if(_blockedChannels.putIfAbsent(channel, Boolean.TRUE)==null) { @@ -1331,7 +1331,7 @@ public class SimpleAMQQueue implements AMQQueue, Subscription.StateListener { //Underfull log message - _logActor.message(_logSubject, QueueMessages.QUE_1004(_atomicQueueSize.get(), _flowResumeCapacity)); + _logActor.message(_logSubject, QueueMessages.QUE_UNDERFULL(_atomicQueueSize.get(), _flowResumeCapacity)); channel.unblock(this); _blockedChannels.remove(channel); @@ -1353,7 +1353,7 @@ public class SimpleAMQQueue implements AMQQueue, Subscription.StateListener { if(_overfull.compareAndSet(true,false)) {//Underfull log message - _logActor.message(_logSubject, QueueMessages.QUE_1004(_atomicQueueSize.get(), _flowResumeCapacity)); + _logActor.message(_logSubject, QueueMessages.QUE_UNDERFULL(_atomicQueueSize.get(), _flowResumeCapacity)); } diff --git a/java/broker/src/main/java/org/apache/qpid/server/registry/ApplicationRegistry.java b/java/broker/src/main/java/org/apache/qpid/server/registry/ApplicationRegistry.java index 1affdd6590..5cb379f10d 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/registry/ApplicationRegistry.java +++ b/java/broker/src/main/java/org/apache/qpid/server/registry/ApplicationRegistry.java @@ -248,7 +248,7 @@ public abstract class ApplicationRegistry implements IApplicationRegistry // _pluginManager.close(); - CurrentActor.get().message(BrokerMessages.BRK_1005()); + CurrentActor.get().message(BrokerMessages.BRK_STOPPED()); } private void unbind() @@ -259,7 +259,7 @@ public abstract class ApplicationRegistry implements IApplicationRegistry { QpidAcceptor acceptor = _acceptors.get(bindAddress); acceptor.getNetworkDriver().close(); - CurrentActor.get().message(BrokerMessages.BRK_1003(acceptor.toString(), bindAddress.getPort())); + CurrentActor.get().message(BrokerMessages.BRK_SHUTTING_DOWN(acceptor.toString(), bindAddress.getPort())); } } } diff --git a/java/broker/src/main/java/org/apache/qpid/server/registry/ConfigurationFileApplicationRegistry.java b/java/broker/src/main/java/org/apache/qpid/server/registry/ConfigurationFileApplicationRegistry.java index 8e8581b66f..f325b53dfb 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/registry/ConfigurationFileApplicationRegistry.java +++ b/java/broker/src/main/java/org/apache/qpid/server/registry/ConfigurationFileApplicationRegistry.java @@ -59,7 +59,7 @@ public class ConfigurationFileApplicationRegistry extends ApplicationRegistry // Set the Actor for current log messages CurrentActor.set(new BrokerActor(_registryName, _rootMessageLogger)); - CurrentActor.get().message(BrokerMessages.BRK_1001(QpidProperties.getReleaseVersion(),QpidProperties.getBuildVersion())); + CurrentActor.get().message(BrokerMessages.BRK_STARTUP(QpidProperties.getReleaseVersion(),QpidProperties.getBuildVersion())); initialiseManagedObjectRegistry(); diff --git a/java/broker/src/main/java/org/apache/qpid/server/store/AbstractMessageStore.java b/java/broker/src/main/java/org/apache/qpid/server/store/AbstractMessageStore.java index f8bc530aa6..ef8f1ab70e 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/store/AbstractMessageStore.java +++ b/java/broker/src/main/java/org/apache/qpid/server/store/AbstractMessageStore.java @@ -34,11 +34,11 @@ public abstract class AbstractMessageStore implements MessageStore public void configure(VirtualHost virtualHost) throws Exception { _logSubject = new MessageStoreLogSubject(virtualHost, this); - CurrentActor.get().message(_logSubject, MessageStoreMessages.MST_1001(this.getClass().getName())); + CurrentActor.get().message(_logSubject, MessageStoreMessages.MST_CREATED(this.getClass().getName())); } public void close() throws Exception { - CurrentActor.get().message(_logSubject,MessageStoreMessages.MST_1003()); + CurrentActor.get().message(_logSubject,MessageStoreMessages.MST_CLOSED()); } } diff --git a/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java b/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java index ba5574d1fa..1764e2324e 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java +++ b/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java @@ -173,7 +173,7 @@ public class DerbyMessageStore implements MessageStore Configuration storeConfiguration, LogSubject logSubject) throws Exception { - CurrentActor.get().message(_logSubject, MessageStoreMessages.MST_1001(this.getClass().getName())); + CurrentActor.get().message(_logSubject, MessageStoreMessages.MST_CREATED(this.getClass().getName())); if(!_configured) { @@ -231,7 +231,7 @@ public class DerbyMessageStore implements MessageStore } } - CurrentActor.get().message(logSubject, MessageStoreMessages.MST_1002(environmentPath.getAbsolutePath())); + CurrentActor.get().message(_logSubject, MessageStoreMessages.MST_STORE_LOCATION(environmentPath.getAbsolutePath())); createOrOpenDatabase(name, databasePath); } @@ -369,6 +369,7 @@ public class DerbyMessageStore implements MessageStore { stateTransition(State.CONFIGURING, State.RECOVERING); + CurrentActor.get().message(_logSubject,MessageStoreMessages.MST_RECOVERY_START()); try { @@ -380,8 +381,6 @@ public class DerbyMessageStore implements MessageStore ConfigurationRecoveryHandler.BindingRecoveryHandler brh = erh.completeExchangeRecovery(); recoverBindings(brh, exchanges); brh.completeBindingRecovery(); - - } catch (SQLException e) { @@ -408,9 +407,6 @@ public class DerbyMessageStore implements MessageStore qrh.queue(queueName, owner, null); queues.add(queueName); - - - } return queues; } @@ -505,7 +501,7 @@ public class DerbyMessageStore implements MessageStore public void close() throws Exception { - CurrentActor.get().message(_logSubject,MessageStoreMessages.MST_1003()); + CurrentActor.get().message(_logSubject,MessageStoreMessages.MST_CLOSED()); _closed.getAndSet(true); } diff --git a/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java b/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java index f43177bfc1..e3e9432e6b 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java +++ b/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java @@ -102,13 +102,13 @@ public class MemoryMessageStore implements MessageStore } int hashtableCapacity = config.getInt(name + "." + HASHTABLE_CAPACITY_CONFIG, DEFAULT_HASHTABLE_CAPACITY); _log.info("Using capacity " + hashtableCapacity + " for hash tables"); - CurrentActor.get().message(_logSubject, MessageStoreMessages.MST_1001(this.getClass().getName())); + CurrentActor.get().message(_logSubject, MessageStoreMessages.MST_CREATED(this.getClass().getName())); } public void close() throws Exception { _closed.getAndSet(true); - CurrentActor.get().message(_logSubject,MessageStoreMessages.MST_1003()); + CurrentActor.get().message(_logSubject,MessageStoreMessages.MST_CLOSED()); } diff --git a/java/broker/src/main/java/org/apache/qpid/server/subscription/SubscriptionImpl.java b/java/broker/src/main/java/org/apache/qpid/server/subscription/SubscriptionImpl.java index bb2e5ae918..5302a3c5d4 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/subscription/SubscriptionImpl.java +++ b/java/broker/src/main/java/org/apache/qpid/server/subscription/SubscriptionImpl.java @@ -365,7 +365,7 @@ public abstract class SubscriptionImpl implements Subscription, FlowCreditManage CurrentActor.get(). message(_logSubject, - SubscriptionMessages.SUB_1001(filterLogString, + SubscriptionMessages.SUB_CREATE(filterLogString, queue.isDurable() && exclusive, filterLogString != null)); } @@ -508,7 +508,7 @@ public abstract class SubscriptionImpl implements Subscription, FlowCreditManage //Log Subscription closed - CurrentActor.get().message(_logSubject, SubscriptionMessages.SUB_1002()); + CurrentActor.get().message(_logSubject, SubscriptionMessages.SUB_CLOSE()); } public boolean isClosed() @@ -596,7 +596,7 @@ public abstract class SubscriptionImpl implements Subscription, FlowCreditManage _stateListener.stateChange(this, State.ACTIVE, State.SUSPENDED); } } - CurrentActor.get().message(_logSubject,SubscriptionMessages.SUB_1003(_state.get().toString())); + CurrentActor.get().message(_logSubject,SubscriptionMessages.SUB_STATE(_state.get().toString())); } public State getState() diff --git a/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostConfigRecoveryHandler.java b/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostConfigRecoveryHandler.java index 7fa5a26436..c543531210 100755 --- a/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostConfigRecoveryHandler.java +++ b/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostConfigRecoveryHandler.java @@ -34,6 +34,7 @@ import org.apache.qpid.server.exchange.Exchange; import org.apache.qpid.server.logging.subjects.MessageStoreLogSubject; import org.apache.qpid.server.logging.actors.CurrentActor; import org.apache.qpid.server.logging.messages.TransactionLogMessages; +import org.apache.qpid.server.logging.messages.MessageStoreMessages; import org.apache.qpid.server.message.AMQMessage; import org.apache.qpid.server.message.ServerMessage; import org.apache.qpid.server.message.MessageTransferMessage; diff --git a/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java b/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java index c321fdf3e0..6826dcf324 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java +++ b/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java @@ -158,7 +158,7 @@ public class VirtualHostImpl implements Accessable, VirtualHost _configuration = hostConfig; _name = hostConfig.getName(); - CurrentActor.get().message(VirtualHostMessages.VHT_1001(_name)); + CurrentActor.get().message(VirtualHostMessages.VHT_CREATED(_name)); if (_name == null || _name.length() == 0) { @@ -482,7 +482,7 @@ public class VirtualHostImpl implements Accessable, VirtualHost _messageStore.close(); } - CurrentActor.get().message(VirtualHostMessages.VHT_1002()); + CurrentActor.get().message(VirtualHostMessages.VHT_CLOSED()); } public ManagedObject getBrokerMBean() diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/LogMessageTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/LogMessageTest.java index 0f3f7bd2b5..2044627be7 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/LogMessageTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/LogMessageTest.java @@ -29,9 +29,11 @@ public class LogMessageTest extends TestCase { /** - * Test that the US local is loadable. + * Test that the US local has a loadable bundle. + * No longer have a specific en_US bundle so cannot verify that that version + * is loaded. */ - public void testUSLocale() + public void testBundle() { Locale usLocal = Locale.US; Locale.setDefault(usLocal); @@ -39,8 +41,6 @@ public class LogMessageTest extends TestCase usLocal); assertNotNull("Unable to load ResourceBundle", _messages); - - assertEquals("Loaded bundle has incorrect locale.", usLocal, _messages.getLocale()); } /** diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/actors/AMQPChannelActorTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/AMQPChannelActorTest.java index 46dc677921..ad8b25a4ac 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/actors/AMQPChannelActorTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/AMQPChannelActorTest.java @@ -20,83 +20,40 @@ */ package org.apache.qpid.server.logging.actors; -import junit.framework.TestCase; import org.apache.commons.configuration.Configuration; import org.apache.commons.configuration.ConfigurationException; import org.apache.commons.configuration.PropertiesConfiguration; import org.apache.qpid.AMQException; import org.apache.qpid.server.configuration.ServerConfiguration; -import org.apache.qpid.server.protocol.AMQProtocolSession; -import org.apache.qpid.server.protocol.InternalTestProtocolSession; -import org.apache.qpid.server.registry.ApplicationRegistry; -import org.apache.qpid.server.virtualhost.VirtualHost; import org.apache.qpid.server.logging.rawloggers.UnitTestMessageLogger; -import org.apache.qpid.server.logging.RootMessageLogger; -import org.apache.qpid.server.logging.RootMessageLoggerImpl; import org.apache.qpid.server.logging.LogSubject; import org.apache.qpid.server.logging.LogMessage; -import org.apache.qpid.server.logging.LogActor; import org.apache.qpid.server.AMQChannel; import java.util.List; /** - * Test : AMQPConnectionActorTest - * Validate the AMQPConnectionActor class. + * Test : AMQPChannelActorTest + * Validate the AMQPChannelActor class. * * The test creates a new AMQPActor and then logs a message using it. * * The test then verifies that the logged message was the only one created and * that the message contains the required message. */ -public class AMQPChannelActorTest extends TestCase +public class AMQPChannelActorTest extends BaseConnectionActorTestCase { - LogActor _amqpActor; - UnitTestMessageLogger _rawLogger; - AMQProtocolSession _session; AMQChannel _channel; - public void setUp() throws Exception, AMQException + @Override + protected void setUpWithConfig(ServerConfiguration serverConfig) throws AMQException { - super.setUp(); - //Highlight that this test will cause a new AR to be created - ApplicationRegistry.getInstance(); - - Configuration config = new PropertiesConfiguration(); - ServerConfiguration serverConfig = new ServerConfiguration(config); - - serverConfig.getConfig().setProperty(ServerConfiguration.STATUS_UPDATES, "on"); - - setUpWithConfig(serverConfig); - } - - private void setUpWithConfig(ServerConfiguration serverConfig) throws AMQException - { - _rawLogger = new UnitTestMessageLogger(); - RootMessageLogger rootLogger = - new RootMessageLoggerImpl(serverConfig, _rawLogger); - - VirtualHost virtualHost = ApplicationRegistry.getInstance(). - getVirtualHostRegistry().getVirtualHosts().iterator().next(); - - // Create a single session for this test. - _session = new InternalTestProtocolSession(virtualHost); - + super.setUpWithConfig(serverConfig); _channel = new AMQChannel(_session, 1, _session.getVirtualHost().getMessageStore()); - _amqpActor = new AMQPChannelActor(_channel, rootLogger); - - } - - public void tearDown() throws Exception - { - _rawLogger.clearLogMessages(); - // Correctly Close the AR we created - ApplicationRegistry.remove(); - - super.tearDown(); + _amqpActor = new AMQPChannelActor(_channel, _rootLogger); } /** diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/actors/AMQPConnectionActorTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/AMQPConnectionActorTest.java index 98c14efe4d..013677461b 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/actors/AMQPConnectionActorTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/AMQPConnectionActorTest.java @@ -20,22 +20,13 @@ */ package org.apache.qpid.server.logging.actors; -import junit.framework.TestCase; import org.apache.commons.configuration.Configuration; import org.apache.commons.configuration.ConfigurationException; import org.apache.commons.configuration.PropertiesConfiguration; import org.apache.qpid.AMQException; import org.apache.qpid.server.configuration.ServerConfiguration; -import org.apache.qpid.server.logging.LogActor; import org.apache.qpid.server.logging.LogMessage; import org.apache.qpid.server.logging.LogSubject; -import org.apache.qpid.server.logging.RootMessageLogger; -import org.apache.qpid.server.logging.RootMessageLoggerImpl; -import org.apache.qpid.server.logging.rawloggers.UnitTestMessageLogger; -import org.apache.qpid.server.protocol.AMQProtocolSession; -import org.apache.qpid.server.protocol.InternalTestProtocolSession; -import org.apache.qpid.server.registry.ApplicationRegistry; -import org.apache.qpid.server.virtualhost.VirtualHost; import java.util.List; @@ -48,51 +39,8 @@ import java.util.List; * The test then verifies that the logged message was the only one created and * that the message contains the required message. */ -public class AMQPConnectionActorTest extends TestCase +public class AMQPConnectionActorTest extends BaseConnectionActorTestCase { - - LogActor _amqpActor; - UnitTestMessageLogger _rawLogger; - - public void setUp() throws Exception, AMQException - { - super.setUp(); - //Highlight that this test will cause a new AR to be created - ApplicationRegistry.getInstance(); - - Configuration config = new PropertiesConfiguration(); - ServerConfiguration serverConfig = new ServerConfiguration(config); - - serverConfig.getConfig().setProperty(ServerConfiguration.STATUS_UPDATES, "on"); - - setUpWithConfig(serverConfig); - } - - public void tearDown() throws Exception - { - _rawLogger.clearLogMessages(); - - // Correctly Close the AR we created - ApplicationRegistry.remove(); - - super.tearDown(); - } - - private void setUpWithConfig(ServerConfiguration serverConfig) throws AMQException - { - _rawLogger = new UnitTestMessageLogger(); - RootMessageLogger rootLogger = - new RootMessageLoggerImpl(serverConfig, _rawLogger); - - VirtualHost virtualHost = ApplicationRegistry.getInstance(). - getVirtualHostRegistry().getVirtualHosts().iterator().next(); - - // Create a single session for this test. - AMQProtocolSession session = new InternalTestProtocolSession(virtualHost); - - _amqpActor = new AMQPConnectionActor(session, rootLogger); - } - /** * Test the AMQPActor logging as a Connection level. * @@ -114,7 +62,7 @@ public class AMQPConnectionActorTest extends TestCase logs.get(0).toString().contains(message)); // Verify that the message has the correct type - assertTrue("Message contains the [con: prefix", + assertTrue("Message does not contain the [con: prefix", logs.get(0).toString().contains("[con:")); // Verify that all the values were presented to the MessageFormatter diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/actors/BaseActorTestCase.java b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/BaseActorTestCase.java new file mode 100644 index 0000000000..dd5632f2b0 --- /dev/null +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/BaseActorTestCase.java @@ -0,0 +1,74 @@ +/* + * + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + * + */ +package org.apache.qpid.server.logging.actors; + +import junit.framework.TestCase; +import org.apache.qpid.AMQException; +import org.apache.qpid.server.registry.ApplicationRegistry; +import org.apache.qpid.server.configuration.ServerConfiguration; +import org.apache.qpid.server.logging.rawloggers.UnitTestMessageLogger; +import org.apache.qpid.server.logging.RootMessageLogger; +import org.apache.qpid.server.logging.RootMessageLoggerImpl; +import org.apache.qpid.server.logging.LogActor; + +import org.apache.commons.configuration.Configuration; +import org.apache.commons.configuration.PropertiesConfiguration; + +public class BaseActorTestCase extends TestCase +{ + protected LogActor _amqpActor; + protected UnitTestMessageLogger _rawLogger; + protected RootMessageLogger _rootLogger; + + public void setUp() throws Exception + { + super.setUp(); + //Highlight that this test will cause a new AR to be created + ApplicationRegistry.getInstance(); + + Configuration config = new PropertiesConfiguration(); + ServerConfiguration serverConfig = new ServerConfiguration(config); + + serverConfig.getConfig().setProperty(ServerConfiguration.STATUS_UPDATES, "on"); + + setUpWithConfig(serverConfig); + } + + public void tearDown() throws Exception + { + _rawLogger.clearLogMessages(); + + // Correctly Close the AR we created + ApplicationRegistry.remove(); + + super.tearDown(); + } + + protected void setUpWithConfig(ServerConfiguration serverConfig) throws AMQException + { + _rawLogger = new UnitTestMessageLogger(); + + _rootLogger = + new RootMessageLoggerImpl(serverConfig, _rawLogger); + } + + +} diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/actors/BaseConnectionActorTestCase.java b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/BaseConnectionActorTestCase.java new file mode 100644 index 0000000000..6e8ecc1313 --- /dev/null +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/BaseConnectionActorTestCase.java @@ -0,0 +1,50 @@ +/* + * + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + * + */ +package org.apache.qpid.server.logging.actors; + +import org.apache.qpid.server.configuration.ServerConfiguration; +import org.apache.qpid.server.virtualhost.VirtualHost; +import org.apache.qpid.server.registry.ApplicationRegistry; +import org.apache.qpid.server.protocol.AMQProtocolSession; +import org.apache.qpid.server.protocol.InternalTestProtocolSession; +import org.apache.qpid.AMQException; + +public class BaseConnectionActorTestCase extends BaseActorTestCase +{ + + protected AMQProtocolSession _session; + + @Override + protected void setUpWithConfig(ServerConfiguration serverConfig) throws AMQException + { + super.setUpWithConfig(serverConfig); + + VirtualHost virtualHost = ApplicationRegistry.getInstance(). + getVirtualHostRegistry().getVirtualHosts().iterator().next(); + + // Create a single session for this test. + _session = new InternalTestProtocolSession(virtualHost); + + _amqpActor = new AMQPConnectionActor(_session, _rootLogger); + } + + +} diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/actors/CurrentActorTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/CurrentActorTest.java index 79fdff2dc6..0d7d0c3dba 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/actors/CurrentActorTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/CurrentActorTest.java @@ -20,15 +20,11 @@ */ package org.apache.qpid.server.logging.actors; -import junit.framework.TestCase; import org.apache.qpid.AMQException; import org.apache.qpid.server.AMQChannel; import org.apache.qpid.server.logging.LogMessage; import org.apache.qpid.server.logging.LogSubject; -import org.apache.qpid.server.protocol.AMQProtocolSession; -import org.apache.qpid.server.protocol.InternalTestProtocolSession; import org.apache.qpid.server.registry.ApplicationRegistry; -import org.apache.qpid.server.virtualhost.VirtualHost; /** * Test : CurrentActorTest @@ -51,38 +47,28 @@ import org.apache.qpid.server.virtualhost.VirtualHost; * is called before one or more threads call get(). This way we can ensure that * the remove does not affect more than the Thread it was called in. */ -public class CurrentActorTest extends TestCase +public class CurrentActorTest extends BaseConnectionActorTestCase { //Set this to be a reasonably large number int THREADS = 10; // Record any exceptions that are thrown by the threads - final Exception[] _errors = new Exception[THREADS]; - - // Create a single session for this test. - AMQProtocolSession _session; - - public void setUp() throws Exception - { - super.setUp(); - // Create a single session for this test. - VirtualHost virtualHost = ApplicationRegistry.getInstance(). - getVirtualHostRegistry().getVirtualHosts().iterator().next(); - - // Create a single session for this test. - _session = new InternalTestProtocolSession(virtualHost); - } - - - @Override - public void tearDown() throws Exception - { - // Correctly Close the AR we created - ApplicationRegistry.remove(); - super.tearDown(); - } - - + Exception[] _errors = new Exception[THREADS]; + + /** + * Test that CurrentActor behaves as LIFO queue. + * + * Test creates two Actors Connection and Channel and then sets the + * CurrentActor. + * + * The test validates that CurrentActor remembers the Connection actor + * after the Channel actor has been removed. + * + * And then finally validates that removing the Connection actor results + * in there being no actors set. + * + * @throws AMQException + */ public void testLIFO() throws AMQException { // Create a new actor using retrieving the rootMessageLogger from @@ -92,6 +78,12 @@ public class CurrentActorTest extends TestCase ApplicationRegistry.getInstance(). getRootMessageLogger()); + /* + * Push the actor on to the stack: + * + * CurrentActor -> Connection + * Stack -> null + */ CurrentActor.set(connectionActor); //Use the Actor to send a simple message @@ -115,8 +107,12 @@ public class CurrentActorTest extends TestCase connectionActor, CurrentActor.get()); /** - * Set the actor to nwo be the Channel actor so testing the ability - * to push the actor on to the stack + * Set the actor to now be the Channel actor so testing the ability + * to push the actor on to the stack: + * + * CurrentActor -> Channel + * Stack -> Connection, null + * */ AMQChannel channel = new AMQChannel(_session, 1, _session.getVirtualHost().getMessageStore()); @@ -149,6 +145,13 @@ public class CurrentActorTest extends TestCase // Remove the ChannelActor from the stack CurrentActor.remove(); + /* + * Pop the actor on to the stack: + * + * CurrentActor -> Connection + * Stack -> null + */ + // Verify we now have the same connection actor as we set earlier assertEquals("Retrieved actor is not as expected ", @@ -157,18 +160,44 @@ public class CurrentActorTest extends TestCase // Verify that removing the our last actor it returns us to the test // default that the ApplicationRegistry sets. CurrentActor.remove(); + /* + * Pop the actor on to the stack: + * + * CurrentActor -> null + */ + assertEquals("CurrentActor not the Test default", TestLogActor.class ,CurrentActor.get().getClass()); } + /** + * Test the setting CurrentActor is done correctly as a ThreadLocal. + * + * The test starts 'THREADS' threads that all set the CurrentActor log + * a message then remove the actor. + * + * Checks are done to ensure that there is no set actor after the remove. + * + * If the ThreadLoacl was not working then having concurrent actor sets + * would result in more than one actor and so the remove will not result + * in the clearing of the CurrentActor + * + */ public void testThreadLocal() { + new Runnable(){ + public void run() + { + System.out.println(_errors[0]); + } + }; + // Setup the threads Thread[] threads = new Thread[THREADS]; for (int count = 0; count < THREADS; count++) { - Runnable test = new Test(count); + Runnable test = new LogMessagesWithAConnectionActor(count); threads[count] = new Thread(test); } @@ -202,11 +231,15 @@ public class CurrentActorTest extends TestCase } } - public class Test implements Runnable + /** + * Creates a new ConnectionActor and logs the given number of messages + * before removing the actor and validating that there is no set actor. + */ + public class LogMessagesWithAConnectionActor implements Runnable { int count; - Test(int count) + LogMessagesWithAConnectionActor(int count) { this.count = count; } diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/actors/ManagementActorTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/ManagementActorTest.java index 9fc1d2a18f..caee84da09 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/actors/ManagementActorTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/ManagementActorTest.java @@ -20,60 +20,45 @@ */ package org.apache.qpid.server.logging.actors; -import junit.framework.TestCase; -import org.apache.commons.configuration.Configuration; -import org.apache.commons.configuration.ConfigurationException; -import org.apache.commons.configuration.PropertiesConfiguration; import org.apache.qpid.server.configuration.ServerConfiguration; -import org.apache.qpid.server.logging.LogActor; import org.apache.qpid.server.logging.LogMessage; import org.apache.qpid.server.logging.LogSubject; -import org.apache.qpid.server.logging.RootMessageLogger; -import org.apache.qpid.server.logging.RootMessageLoggerImpl; -import org.apache.qpid.server.logging.rawloggers.UnitTestMessageLogger; +import org.apache.qpid.AMQException; import java.util.List; /** - * Test : AMQPConnectionActorTest - * Validate the AMQPConnectionActor class. + * Test : AMQPManagementActorTest + * Validate the AMQPManagementActor class. * * The test creates a new AMQPActor and then logs a message using it. * * The test then verifies that the logged message was the only one created and * that the message contains the required message. */ -public class ManagementActorTest extends TestCase +public class ManagementActorTest extends BaseActorTestCase { - LogActor _amqpActor; - UnitTestMessageLogger _rawLogger; private static final String IP = "127.0.0.1"; private static final String CONNECTION_ID = "1"; private String _threadName; - public void setUp() throws ConfigurationException + @Override + protected void setUpWithConfig(ServerConfiguration serverConfig) throws AMQException { - Configuration config = new PropertiesConfiguration(); - ServerConfiguration serverConfig = new ServerConfiguration(config); - - serverConfig.getConfig().setProperty(ServerConfiguration.STATUS_UPDATES, "on"); - - _rawLogger = new UnitTestMessageLogger(); - RootMessageLogger rootLogger = - new RootMessageLoggerImpl(serverConfig, _rawLogger); - - _amqpActor = new ManagementActor(rootLogger); + super.setUpWithConfig(serverConfig); + _amqpActor = new ManagementActor(_rootLogger); // Set the thread name to be the same as a RMI JMX Connection would use _threadName = Thread.currentThread().getName(); Thread.currentThread().setName("RMI TCP Connection(" + CONNECTION_ID + ")-" + IP); } - public void tearDown() + @Override + public void tearDown() throws Exception { Thread.currentThread().setName(_threadName); - _rawLogger.clearLogMessages(); + super.tearDown(); } /** @@ -117,7 +102,7 @@ public class ManagementActorTest extends TestCase logs.get(0).toString().contains("{")); // Verify that the message has the correct type - assertTrue("Message contains the [mng: prefix", + assertTrue("Message does not contain the [mng: prefix", logs.get(0).toString().contains("[mng:")); // Verify that the logged message does not contains the 'ch:' marker diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/actors/QueueActorTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/QueueActorTest.java index 727b83c60b..bf8fd86f85 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/actors/QueueActorTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/QueueActorTest.java @@ -20,49 +20,27 @@ */ package org.apache.qpid.server.logging.actors; -import junit.framework.TestCase; -import org.apache.commons.configuration.Configuration; -import org.apache.commons.configuration.ConfigurationException; -import org.apache.commons.configuration.PropertiesConfiguration; import org.apache.qpid.server.configuration.ServerConfiguration; -import org.apache.qpid.server.logging.LogActor; import org.apache.qpid.server.logging.LogMessage; import org.apache.qpid.server.logging.LogSubject; -import org.apache.qpid.server.logging.RootMessageLogger; -import org.apache.qpid.server.logging.RootMessageLoggerImpl; -import org.apache.qpid.server.logging.rawloggers.UnitTestMessageLogger; import org.apache.qpid.server.queue.MockAMQQueue; -import org.apache.qpid.server.registry.ApplicationRegistry; +import org.apache.qpid.AMQException; import java.util.List; -public class QueueActorTest extends TestCase +public class QueueActorTest extends BaseConnectionActorTestCase { - LogActor _amqpActor; - UnitTestMessageLogger _rawLogger; - public void setUp() throws ConfigurationException + @Override + protected void setUpWithConfig(ServerConfiguration serverConfig) throws AMQException { - Configuration config = new PropertiesConfiguration(); - ServerConfiguration serverConfig = new ServerConfiguration(config); - - serverConfig.getConfig().setProperty(ServerConfiguration.STATUS_UPDATES, "on"); - - _rawLogger = new UnitTestMessageLogger(); - RootMessageLogger rootLogger = - new RootMessageLoggerImpl(serverConfig, _rawLogger); + super.setUpWithConfig(serverConfig); MockAMQQueue queue = new MockAMQQueue(getName()); - queue.setVirtualHost(ApplicationRegistry.getInstance().getVirtualHostRegistry().getVirtualHosts().iterator().next()); + queue.setVirtualHost(_session.getVirtualHost()); - _amqpActor = new QueueActor(queue, rootLogger); - } - - public void tearDown() - { - _rawLogger.clearLogMessages(); - ApplicationRegistry.remove(); + _amqpActor = new QueueActor(queue, _rootLogger); } /** diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/actors/SubscriptionActorTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/SubscriptionActorTest.java index 6b09087eef..c86ffd4872 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/actors/SubscriptionActorTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/SubscriptionActorTest.java @@ -20,23 +20,13 @@ */ package org.apache.qpid.server.logging.actors; -import junit.framework.TestCase; -import org.apache.commons.configuration.Configuration; -import org.apache.commons.configuration.ConfigurationException; -import org.apache.commons.configuration.PropertiesConfiguration; import org.apache.qpid.server.configuration.ServerConfiguration; -import org.apache.qpid.server.logging.LogActor; import org.apache.qpid.server.logging.LogMessage; import org.apache.qpid.server.logging.LogSubject; -import org.apache.qpid.server.logging.RootMessageLogger; -import org.apache.qpid.server.logging.RootMessageLoggerImpl; -import org.apache.qpid.server.logging.rawloggers.UnitTestMessageLogger; import org.apache.qpid.server.subscription.MockSubscription; -import org.apache.qpid.server.queue.AMQQueue; import org.apache.qpid.server.queue.MockAMQQueue; -import org.apache.qpid.server.registry.ApplicationRegistry; +import org.apache.qpid.AMQException; -import java.security.Principal; import java.util.List; /** @@ -48,38 +38,24 @@ import java.util.List; * The test then verifies that the logged message was the only one created and * that the message contains the required message. */ -public class SubscriptionActorTest extends TestCase +public class SubscriptionActorTest extends BaseConnectionActorTestCase { - LogActor _amqpActor; - UnitTestMessageLogger _rawLogger; - - public void setUp() throws ConfigurationException + @Override + protected void setUpWithConfig(ServerConfiguration serverConfig) throws AMQException { - Configuration config = new PropertiesConfiguration(); - ServerConfiguration serverConfig = new ServerConfiguration(config); - - serverConfig.getConfig().setProperty(ServerConfiguration.STATUS_UPDATES, "on"); + super.setUpWithConfig(serverConfig); - _rawLogger = new UnitTestMessageLogger(); - RootMessageLogger rootLogger = - new RootMessageLoggerImpl(serverConfig, _rawLogger); MockSubscription mockSubscription = new MockSubscription(); MockAMQQueue queue = new MockAMQQueue(getName()); - queue.setVirtualHost(ApplicationRegistry.getInstance().getVirtualHostRegistry().getVirtualHosts().iterator().next()); + queue.setVirtualHost(_session.getVirtualHost()); mockSubscription.setQueue(queue,false); - _amqpActor = new SubscriptionActor(rootLogger, mockSubscription); - } - - public void tearDown() - { - _rawLogger.clearLogMessages(); - ApplicationRegistry.remove(); + _amqpActor = new SubscriptionActor(_rootLogger, mockSubscription); } /** diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/actors/TestLogActor.java b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/TestLogActor.java index acab5b28d2..30f4e16e42 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/actors/TestLogActor.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/actors/TestLogActor.java @@ -27,7 +27,11 @@ public class TestLogActor extends AbstractActor public TestLogActor(RootMessageLogger rootLogger) { super(rootLogger); - _logString = "[Test Actor] "; + } + + public String getLogMessage() + { + return "[Test Actor] "; } }
\ No newline at end of file diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/AbstractTestMessages.java b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/AbstractTestMessages.java index b9b222755d..25760a6d65 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/AbstractTestMessages.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/AbstractTestMessages.java @@ -22,7 +22,6 @@ package org.apache.qpid.server.logging.messages; import junit.framework.TestCase; import org.apache.commons.configuration.Configuration; -import org.apache.commons.configuration.ConfigurationException; import org.apache.commons.configuration.PropertiesConfiguration; import org.apache.qpid.server.configuration.ServerConfiguration; import org.apache.qpid.server.logging.LogActor; @@ -87,9 +86,8 @@ public abstract class AbstractTestMessages extends TestCase * * @param logs the logs generated during test run * @param tag the tag to check for - * @param expected + * @param expected the expected log messages * - * @return the log message section for further testing */ protected void validateLogMessage(List<Object> logs, String tag, String[] expected) { diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/BindingMessagesTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/BindingMessagesTest.java index b2182bb1b2..7a750baf06 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/BindingMessagesTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/BindingMessagesTest.java @@ -22,12 +22,15 @@ package org.apache.qpid.server.logging.messages; import java.util.List; +/** + * Test BND Log Messages + */ public class BindingMessagesTest extends AbstractTestMessages { - public void testMessage1001_NoArgs() + public void testBindCreate_NoArgs() { - _logMessage = BindingMessages.BND_1001(null, false); + _logMessage = BindingMessages.BND_CREATED(null, false); List<Object> log = performLog(); String[] expected = {"Create"}; @@ -35,11 +38,11 @@ public class BindingMessagesTest extends AbstractTestMessages validateLogMessage(log, "BND-1001", expected); } - public void testMessage1001_Args() + public void testBindCreate_Args() { String arguments = "arguments"; - _logMessage = BindingMessages.BND_1001(arguments, true); + _logMessage = BindingMessages.BND_CREATED(arguments, true); List<Object> log = performLog(); String[] expected = {"Create", ": Arguments :", arguments}; @@ -47,9 +50,9 @@ public class BindingMessagesTest extends AbstractTestMessages validateLogMessage(log, "BND-1001", expected); } - public void testMessage1002() + public void testBindDelete() { - _logMessage = BindingMessages.BND_1002(); + _logMessage = BindingMessages.BND_DELETED(); List<Object> log = performLog(); diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/BrokerMessagesTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/BrokerMessagesTest.java index 65dcea1e25..17306b2e2a 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/BrokerMessagesTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/BrokerMessagesTest.java @@ -22,14 +22,17 @@ package org.apache.qpid.server.logging.messages; import java.util.List; +/** + * Test BRK log Messages + */ public class BrokerMessagesTest extends AbstractTestMessages { - public void testMessage1001() + public void testBrokerStartup() { String version = "Qpid 0.6"; String build = "796936M"; - _logMessage = BrokerMessages.BRK_1001(version, build); + _logMessage = BrokerMessages.BRK_STARTUP(version, build); List<Object> log = performLog(); String[] expected = {"Startup :", "Version:", version, "Build:", build}; @@ -37,12 +40,12 @@ public class BrokerMessagesTest extends AbstractTestMessages validateLogMessage(log, "BRK-1001", expected); } - public void testMessage1002() + public void testBrokerListening() { String transport = "TCP"; Integer port = 2765; - _logMessage = BrokerMessages.BRK_1002(transport, port); + _logMessage = BrokerMessages.BRK_LISTENING(transport, port); List<Object> log = performLog(); @@ -52,12 +55,12 @@ public class BrokerMessagesTest extends AbstractTestMessages validateLogMessage(log, "BRK-1002", expected); } - public void testMessage1003() + public void testBrokerShuttingDown() { String transport = "TCP"; Integer port = 2765; - _logMessage = BrokerMessages.BRK_1003(transport, port); + _logMessage = BrokerMessages.BRK_SHUTTING_DOWN(transport, port); List<Object> log = performLog(); @@ -66,9 +69,9 @@ public class BrokerMessagesTest extends AbstractTestMessages validateLogMessage(log, "BRK-1003", expected); } - public void testMessage1004() + public void testBrokerReady() { - _logMessage = BrokerMessages.BRK_1004(); + _logMessage = BrokerMessages.BRK_READY(); List<Object> log = performLog(); String[] expected = {"Ready"}; @@ -76,9 +79,9 @@ public class BrokerMessagesTest extends AbstractTestMessages validateLogMessage(log, "BRK-1004", expected); } - public void testMessage1005() + public void testBrokerStopped() { - _logMessage = BrokerMessages.BRK_1005(); + _logMessage = BrokerMessages.BRK_STOPPED(); List<Object> log = performLog(); String[] expected = {"Stopped"}; @@ -86,11 +89,11 @@ public class BrokerMessagesTest extends AbstractTestMessages validateLogMessage(log, "BRK-1005", expected); } - public void testMessage1006() + public void testBrokerConfig() { String path = "/file/path/to/configuration.xml"; - _logMessage = BrokerMessages.BRK_1006(path); + _logMessage = BrokerMessages.BRK_CONFIG(path); List<Object> log = performLog(); String[] expected = {"Using configuration :", path}; @@ -98,11 +101,11 @@ public class BrokerMessagesTest extends AbstractTestMessages validateLogMessage(log, "BRK-1006", expected); } - public void testMessage1007() + public void testBrokerLogConfig() { String path = "/file/path/to/configuration.xml"; - _logMessage = BrokerMessages.BRK_1007(path); + _logMessage = BrokerMessages.BRK_LOG_CONFIG(path); List<Object> log = performLog(); String[] expected = {"Using logging configuration :", path}; diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ChannelMessagesTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ChannelMessagesTest.java index b4dd3da2e6..2d414e9e95 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ChannelMessagesTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ChannelMessagesTest.java @@ -20,14 +20,16 @@ */ package org.apache.qpid.server.logging.messages; -import java.text.MessageFormat; import java.util.List; +/** + * Test CHN Log Messges + */ public class ChannelMessagesTest extends AbstractTestMessages { - public void testMessage1001() + public void testChannelCreate() { - _logMessage = ChannelMessages.CHN_1001(); + _logMessage = ChannelMessages.CHN_CREATE(); List<Object> log = performLog(); // We use the MessageFormat here as that is what the ChannelMessage @@ -37,11 +39,11 @@ public class ChannelMessagesTest extends AbstractTestMessages validateLogMessage(log, "CHN-1001", expected); } - public void testMessage1002() + public void testChannelFlow() { String flow = "ON"; - _logMessage = ChannelMessages.CHN_1002(flow); + _logMessage = ChannelMessages.CHN_FLOW(flow); List<Object> log = performLog(); String[] expected = {"Flow", flow}; @@ -49,9 +51,9 @@ public class ChannelMessagesTest extends AbstractTestMessages validateLogMessage(log, "CHN-1002", expected); } - public void testMessage1003() + public void testChannelClose() { - _logMessage = ChannelMessages.CHN_1003(); + _logMessage = ChannelMessages.CHN_CLOSE(); List<Object> log = performLog(); String[] expected = {"Close"}; diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ConnectionMessagesTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ConnectionMessagesTest.java index d234c88210..6003cafc95 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ConnectionMessagesTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ConnectionMessagesTest.java @@ -22,14 +22,17 @@ package org.apache.qpid.server.logging.messages; import java.util.List; +/** + * Test CON Log Messages + */ public class ConnectionMessagesTest extends AbstractTestMessages { - public void testMessage1001_WithClientIDProtocolVersion() + public void testConnectionOpen_WithClientIDProtocolVersion() { String clientID = "client"; String protocolVersion = "8-0"; - _logMessage = ConnectionMessages.CON_1001(clientID, protocolVersion, true , true); + _logMessage = ConnectionMessages.CON_OPEN(clientID, protocolVersion, true , true); List<Object> log = performLog(); String[] expected = {"Open :", "Client ID", clientID, @@ -38,11 +41,11 @@ public class ConnectionMessagesTest extends AbstractTestMessages validateLogMessage(log, "CON-1001", expected); } - public void testMessage1001_WithClientIDNoProtocolVersion() + public void testConnectionOpen_WithClientIDNoProtocolVersion() { String clientID = "client"; - _logMessage = ConnectionMessages.CON_1001(clientID, null,true, false); + _logMessage = ConnectionMessages.CON_OPEN(clientID, null,true, false); List<Object> log = performLog(); String[] expected = {"Open :", "Client ID", clientID}; @@ -50,11 +53,11 @@ public class ConnectionMessagesTest extends AbstractTestMessages validateLogMessage(log, "CON-1001", expected); } - public void testMessage1001_WithNOClientIDProtocolVersion() + public void testConnectionOpen_WithNOClientIDProtocolVersion() { String protocolVersion = "8-0"; - _logMessage = ConnectionMessages.CON_1001(null, protocolVersion, false , true); + _logMessage = ConnectionMessages.CON_OPEN(null, protocolVersion, false , true); List<Object> log = performLog(); String[] expected = {"Open", ": Protocol Version :", protocolVersion}; @@ -62,9 +65,9 @@ public class ConnectionMessagesTest extends AbstractTestMessages validateLogMessage(log, "CON-1001", expected); } - public void testMessage1001_WithNoClientIDNoProtocolVersion() + public void testConnectionOpen_WithNoClientIDNoProtocolVersion() { - _logMessage = ConnectionMessages.CON_1001(null, null,false, false); + _logMessage = ConnectionMessages.CON_OPEN(null, null,false, false); List<Object> log = performLog(); String[] expected = {"Open"}; @@ -74,9 +77,9 @@ public class ConnectionMessagesTest extends AbstractTestMessages - public void testMessage1002() + public void testConnectionClose() { - _logMessage = ConnectionMessages.CON_1002(); + _logMessage = ConnectionMessages.CON_CLOSE(); List<Object> log = performLog(); String[] expected = {"Close"}; diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ExchangeMessagesTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ExchangeMessagesTest.java index 831ede3e0c..072f671fec 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ExchangeMessagesTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ExchangeMessagesTest.java @@ -25,9 +25,12 @@ import org.apache.qpid.server.registry.ApplicationRegistry; import java.util.List; +/** + * Test EXH Log Messages + */ public class ExchangeMessagesTest extends AbstractTestMessages { - public void testMessage1001_Transient() + public void testExchangeCreated_Transient() { // Get the Default Exchange on the Test Vhost for testing Exchange exchange = ApplicationRegistry.getInstance(). @@ -37,7 +40,7 @@ public class ExchangeMessagesTest extends AbstractTestMessages String type = exchange.getType().toString(); String name = exchange.getName().toString(); - _logMessage = ExchangeMessages.EXH_1001(type, name, false); + _logMessage = ExchangeMessages.EXH_CREATED(type, name, false); List<Object> log = performLog(); String[] expected = {"Create :", "Type:", type, "Name:", name}; @@ -45,7 +48,7 @@ public class ExchangeMessagesTest extends AbstractTestMessages validateLogMessage(log, "EXH-1001", expected); } - public void testMessage1001_Persistent() + public void testExchangeCreated_Persistent() { // Get the Default Exchange on the Test Vhost for testing Exchange exchange = ApplicationRegistry.getInstance(). @@ -55,7 +58,7 @@ public class ExchangeMessagesTest extends AbstractTestMessages String type = exchange.getType().toString(); String name = exchange.getName().toString(); - _logMessage = ExchangeMessages.EXH_1001(type, name, true); + _logMessage = ExchangeMessages.EXH_CREATED(type, name, true); List<Object> log = performLog(); String[] expected = {"Create :", "Durable", "Type:", type, "Name:", name}; @@ -64,9 +67,9 @@ public class ExchangeMessagesTest extends AbstractTestMessages } - public void testMessage1002() + public void testExchangeDeleted() { - _logMessage = ExchangeMessages.EXH_1002(); + _logMessage = ExchangeMessages.EXH_DELETED(); List<Object> log = performLog(); String[] expected = {"Deleted"}; diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ManagementConsoleMessagesTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ManagementConsoleMessagesTest.java index e9b40c5dad..9b1ab2c14d 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ManagementConsoleMessagesTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ManagementConsoleMessagesTest.java @@ -22,11 +22,14 @@ package org.apache.qpid.server.logging.messages; import java.util.List; +/** + * Test MNG Log Messages + */ public class ManagementConsoleMessagesTest extends AbstractTestMessages { - public void testMessage1001() + public void testManagementStartup() { - _logMessage = ManagementConsoleMessages.MNG_1001(); + _logMessage = ManagementConsoleMessages.MNG_STARTUP(); List<Object> log = performLog(); String[] expected = {"Startup"}; @@ -34,12 +37,12 @@ public class ManagementConsoleMessagesTest extends AbstractTestMessages validateLogMessage(log, "MNG-1001", expected); } - public void testMessage1002() + public void testManagementListening() { String transport = "JMX"; Integer port = 8889; - _logMessage = ManagementConsoleMessages.MNG_1002(transport, port); + _logMessage = ManagementConsoleMessages.MNG_LISTENING(transport, port); List<Object> log = performLog(); String[] expected = {"Starting :", transport, ": Listening on port", String.valueOf(port)}; @@ -47,12 +50,12 @@ public class ManagementConsoleMessagesTest extends AbstractTestMessages validateLogMessage(log, "MNG-1002", expected); } - public void testMessage1003() + public void testManagementShuttingDown() { String transport = "JMX"; Integer port = 8889; - _logMessage = ManagementConsoleMessages.MNG_1003(transport, port); + _logMessage = ManagementConsoleMessages.MNG_SHUTTING_DOWN(transport, port); List<Object> log = performLog(); String[] expected = {"Shuting down :", transport, ": port", String.valueOf(port)}; @@ -60,9 +63,9 @@ public class ManagementConsoleMessagesTest extends AbstractTestMessages validateLogMessage(log, "MNG-1003", expected); } - public void testMessage1004() + public void testManagementReady() { - _logMessage = ManagementConsoleMessages.MNG_1004(); + _logMessage = ManagementConsoleMessages.MNG_READY(); List<Object> log = performLog(); String[] expected = {"Ready"}; @@ -70,9 +73,9 @@ public class ManagementConsoleMessagesTest extends AbstractTestMessages validateLogMessage(log, "MNG-1004", expected); } - public void testMessage1005() + public void testManagementStopped() { - _logMessage = ManagementConsoleMessages.MNG_1005(); + _logMessage = ManagementConsoleMessages.MNG_STOPPED(); List<Object> log = performLog(); String[] expected = {"Stopped"}; @@ -80,11 +83,11 @@ public class ManagementConsoleMessagesTest extends AbstractTestMessages validateLogMessage(log, "MNG-1005", expected); } - public void testMessage1006() + public void testManagementSSLKeyStore() { String path = "/path/to/the/keystore/files.jks"; - _logMessage = ManagementConsoleMessages.MNG_1006(path); + _logMessage = ManagementConsoleMessages.MNG_SSL_KEYSTORE(path); List<Object> log = performLog(); String[] expected = {"Using SSL Keystore :", path}; diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/MessageStoreMessagesTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/MessageStoreMessagesTest.java index e3280a4076..21041fc611 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/MessageStoreMessagesTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/MessageStoreMessagesTest.java @@ -23,13 +23,16 @@ package org.apache.qpid.server.logging.messages; import java.text.MessageFormat; import java.util.List; +/** + * Test MST Log Messages + */ public class MessageStoreMessagesTest extends AbstractTestMessages { - public void testMessage1001() + public void testMessageStoreCreated() { String name = "DerbyMessageStore"; - _logMessage = MessageStoreMessages.MST_1001(name); + _logMessage = MessageStoreMessages.MST_CREATED(name); List<Object> log = performLog(); String[] expected = {"Created :", name}; @@ -37,21 +40,21 @@ public class MessageStoreMessagesTest extends AbstractTestMessages validateLogMessage(log, "MST-1001", expected); } - public void testMessage1002() + public void testMessageStoreStoreLocation() { String location = "/path/to/the/message/store.files"; - _logMessage = ConfigStoreMessages.CFG_1002(location); + _logMessage = MessageStoreMessages.MST_STORE_LOCATION(location); List<Object> log = performLog(); String[] expected = {"Store location :", location}; - validateLogMessage(log, "CFG-1002", expected); + validateLogMessage(log, "MST-1002", expected); } - public void testMessage1003() + public void testMessageStoreClosed() { - _logMessage = MessageStoreMessages.MST_1003(); + _logMessage = MessageStoreMessages.MST_CLOSED(); List<Object> log = performLog(); String[] expected = {"Closed"}; @@ -59,21 +62,21 @@ public class MessageStoreMessagesTest extends AbstractTestMessages validateLogMessage(log, "MST-1003", expected); } - /* public void testMessage1004() + public void testMessageStoreRecoveryStart() { - _logMessage = MessageStoreMessages.MST_1004(null,false); + _logMessage = MessageStoreMessages.MST_RECOVERY_START(); List<Object> log = performLog(); String[] expected = {"Recovery Start"}; validateLogMessage(log, "MST-1004", expected); } - - public void testMessage1004_withQueue() +/* + public void testMessageStoreRecoveryStart_withQueue() { String queueName = "testQueue"; - _logMessage = MessageStoreMessages.MST_1004(queueName, true); + _logMessage = MessageStoreMessages.MST_RECOVERY_START(queueName, true); List<Object> log = performLog(); String[] expected = {"Recovery Start :", queueName}; @@ -81,12 +84,12 @@ public class MessageStoreMessagesTest extends AbstractTestMessages validateLogMessage(log, "MST-1004", expected); } - public void testMessage1005() + public void testMessageStoreRecovered() { String queueName = "testQueue"; Integer messasgeCount = 2000; - _logMessage = MessageStoreMessages.MST_1005(messasgeCount, queueName); + _logMessage = MessageStoreMessages.MST_RECOVERED(messasgeCount, queueName); List<Object> log = performLog(); // Here we use MessageFormat to ensure the messasgeCount of 2000 is @@ -98,9 +101,9 @@ public class MessageStoreMessagesTest extends AbstractTestMessages validateLogMessage(log, "MST-1005", expected); } - public void testMessage1006() + public void testMessageStoreRecoveryComplete() { - _logMessage = MessageStoreMessages.MST_1006(null,false); + _logMessage = MessageStoreMessages.MST_RECOVERY_COMPLETE(null,false); List<Object> log = performLog(); String[] expected = {"Recovery Complete"}; @@ -108,11 +111,11 @@ public class MessageStoreMessagesTest extends AbstractTestMessages validateLogMessage(log, "MST-1006", expected); } - public void testMessage1006_withQueue() + public void testMessageStoreRecoveryComplete_withQueue() { String queueName = "testQueue"; - _logMessage = MessageStoreMessages.MST_1006(queueName, true); + _logMessage = MessageStoreMessages.MST_RECOVERY_COMPLETE(queueName, true); List<Object> log = performLog(); String[] expected = {"Recovery Complete :", queueName}; diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/QueueMessagesTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/QueueMessagesTest.java index c5d544ba84..417ae31d13 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/QueueMessagesTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/QueueMessagesTest.java @@ -22,14 +22,17 @@ package org.apache.qpid.server.logging.messages; import java.util.List; +/** + * Test QUE Log Messages + */ public class QueueMessagesTest extends AbstractTestMessages { - public void testMessage1001ALL() + public void testQueueCreatedALL() { String owner = "guest"; Integer priority = 3; - _logMessage = QueueMessages.QUE_1001(owner, priority, true, true, true, true, true); + _logMessage = QueueMessages.QUE_CREATED(owner, priority, true, true, true, true, true); List<Object> log = performLog(); String[] expected = {"Create :", "Owner:", owner, "AutoDelete", @@ -39,11 +42,11 @@ public class QueueMessagesTest extends AbstractTestMessages validateLogMessage(log, "QUE-1001", expected); } - public void testMessage1001OwnerAutoDelete() + public void testQueueCreatedOwnerAutoDelete() { String owner = "guest"; - _logMessage = QueueMessages.QUE_1001(owner, null, true, true, false, false, false); + _logMessage = QueueMessages.QUE_CREATED(owner, null, true, true, false, false, false); List<Object> log = performLog(); String[] expected = {"Create :", "Owner:", owner, "AutoDelete"}; @@ -51,12 +54,12 @@ public class QueueMessagesTest extends AbstractTestMessages validateLogMessage(log, "QUE-1001", expected); } - public void testMessage1001OwnerPriority() + public void testQueueCreatedOwnerPriority() { String owner = "guest"; Integer priority = 3; - _logMessage = QueueMessages.QUE_1001(owner, priority, true, false, false, false, true); + _logMessage = QueueMessages.QUE_CREATED(owner, priority, true, false, false, false, true); List<Object> log = performLog(); String[] expected = {"Create :", "Owner:", owner, "Priority:", @@ -65,12 +68,12 @@ public class QueueMessagesTest extends AbstractTestMessages validateLogMessage(log, "QUE-1001", expected); } - public void testMessage1001OwnerAutoDeletePriority() + public void testQueueCreatedOwnerAutoDeletePriority() { String owner = "guest"; Integer priority = 3; - _logMessage = QueueMessages.QUE_1001(owner, priority, true, true, false, false, true); + _logMessage = QueueMessages.QUE_CREATED(owner, priority, true, true, false, false, true); List<Object> log = performLog(); String[] expected = {"Create :", "Owner:", owner, "AutoDelete", @@ -80,11 +83,11 @@ public class QueueMessagesTest extends AbstractTestMessages validateLogMessage(log, "QUE-1001", expected); } - public void testMessage1001OwnerAutoDeleteTransient() + public void testQueueCreatedOwnerAutoDeleteTransient() { String owner = "guest"; - _logMessage = QueueMessages.QUE_1001(owner, null, true, true, false, true, false); + _logMessage = QueueMessages.QUE_CREATED(owner, null, true, true, false, true, false); List<Object> log = performLog(); String[] expected = {"Create :", "Owner:", owner, "AutoDelete", @@ -93,12 +96,12 @@ public class QueueMessagesTest extends AbstractTestMessages validateLogMessage(log, "QUE-1001", expected); } - public void testMessage1001OwnerAutoDeleteTransientPriority() + public void testQueueCreatedOwnerAutoDeleteTransientPriority() { String owner = "guest"; Integer priority = 3; - _logMessage = QueueMessages.QUE_1001(owner, priority, true, true, false, true, true); + _logMessage = QueueMessages.QUE_CREATED(owner, priority, true, true, false, true, true); List<Object> log = performLog(); String[] expected = {"Create :", "Owner:", owner, "AutoDelete", @@ -108,11 +111,11 @@ public class QueueMessagesTest extends AbstractTestMessages validateLogMessage(log, "QUE-1001", expected); } - public void testMessage1001OwnerAutoDeleteDurable() + public void testQueueCreatedOwnerAutoDeleteDurable() { String owner = "guest"; - _logMessage = QueueMessages.QUE_1001(owner, null, true, true, true, false, false); + _logMessage = QueueMessages.QUE_CREATED(owner, null, true, true, true, false, false); List<Object> log = performLog(); String[] expected = {"Create :", "Owner:", owner, "AutoDelete", @@ -121,12 +124,12 @@ public class QueueMessagesTest extends AbstractTestMessages validateLogMessage(log, "QUE-1001", expected); } - public void testMessage1001OwnerAutoDeleteDurablePriority() + public void testQueueCreatedOwnerAutoDeleteDurablePriority() { String owner = "guest"; Integer priority = 3; - _logMessage = QueueMessages.QUE_1001(owner, priority, true, true, true, false, true); + _logMessage = QueueMessages.QUE_CREATED(owner, priority, true, true, true, false, true); List<Object> log = performLog(); String[] expected = {"Create :", "Owner:", owner, "AutoDelete", @@ -136,9 +139,9 @@ public class QueueMessagesTest extends AbstractTestMessages validateLogMessage(log, "QUE-1001", expected); } - public void testMessage1001AutoDelete() + public void testQueueCreatedAutoDelete() { - _logMessage = QueueMessages.QUE_1001(null, null, false, true, false, false, false); + _logMessage = QueueMessages.QUE_CREATED(null, null, false, true, false, false, false); List<Object> log = performLog(); String[] expected = {"Create :", "AutoDelete"}; @@ -146,11 +149,11 @@ public class QueueMessagesTest extends AbstractTestMessages validateLogMessage(log, "QUE-1001", expected); } - public void testMessage1001Priority() + public void testQueueCreatedPriority() { Integer priority = 3; - _logMessage = QueueMessages.QUE_1001(null, priority, false, false, false, false, true); + _logMessage = QueueMessages.QUE_CREATED(null, priority, false, false, false, false, true); List<Object> log = performLog(); String[] expected = {"Create :", "Priority:", @@ -159,11 +162,11 @@ public class QueueMessagesTest extends AbstractTestMessages validateLogMessage(log, "QUE-1001", expected); } - public void testMessage1001AutoDeletePriority() + public void testQueueCreatedAutoDeletePriority() { Integer priority = 3; - _logMessage = QueueMessages.QUE_1001(null, priority, false, true, false, false, true); + _logMessage = QueueMessages.QUE_CREATED(null, priority, false, true, false, false, true); List<Object> log = performLog(); String[] expected = {"Create :", "AutoDelete", @@ -173,9 +176,9 @@ public class QueueMessagesTest extends AbstractTestMessages validateLogMessage(log, "QUE-1001", expected); } - public void testMessage1001AutoDeleteTransient() + public void testQueueCreatedAutoDeleteTransient() { - _logMessage = QueueMessages.QUE_1001(null, null, false, true, false, true, false); + _logMessage = QueueMessages.QUE_CREATED(null, null, false, true, false, true, false); List<Object> log = performLog(); String[] expected = {"Create :", "AutoDelete", @@ -184,11 +187,11 @@ public class QueueMessagesTest extends AbstractTestMessages validateLogMessage(log, "QUE-1001", expected); } - public void testMessage1001AutoDeleteTransientPriority() + public void testQueueCreatedAutoDeleteTransientPriority() { Integer priority = 3; - _logMessage = QueueMessages.QUE_1001(null, priority, false, true, false, true, true); + _logMessage = QueueMessages.QUE_CREATED(null, priority, false, true, false, true, true); List<Object> log = performLog(); String[] expected = {"Create :", "AutoDelete", @@ -198,9 +201,9 @@ public class QueueMessagesTest extends AbstractTestMessages validateLogMessage(log, "QUE-1001", expected); } - public void testMessage1001AutoDeleteDurable() + public void testQueueCreatedAutoDeleteDurable() { - _logMessage = QueueMessages.QUE_1001(null, null, false, true, true, false, false); + _logMessage = QueueMessages.QUE_CREATED(null, null, false, true, true, false, false); List<Object> log = performLog(); String[] expected = {"Create :", "AutoDelete", @@ -209,11 +212,11 @@ public class QueueMessagesTest extends AbstractTestMessages validateLogMessage(log, "QUE-1001", expected); } - public void testMessage1001AutoDeleteDurablePriority() + public void testQueueCreatedAutoDeleteDurablePriority() { Integer priority = 3; - _logMessage = QueueMessages.QUE_1001(null, priority, false, true, true, false, true); + _logMessage = QueueMessages.QUE_CREATED(null, priority, false, true, true, false, true); List<Object> log = performLog(); String[] expected = {"Create :", "AutoDelete", @@ -223,9 +226,9 @@ public class QueueMessagesTest extends AbstractTestMessages validateLogMessage(log, "QUE-1001", expected); } - public void testMessage1002() + public void testQueueDeleted() { - _logMessage = QueueMessages.QUE_1002(); + _logMessage = QueueMessages.QUE_DELETED(); List<Object> log = performLog(); String[] expected = {"Deleted"}; diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/SubscriptionMessagesTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/SubscriptionMessagesTest.java index 7752b873b6..b22f2e0b85 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/SubscriptionMessagesTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/SubscriptionMessagesTest.java @@ -22,13 +22,16 @@ package org.apache.qpid.server.logging.messages; import java.util.List; +/** + * Test SUB Log Messages + */ public class SubscriptionMessagesTest extends AbstractTestMessages { - public void testMessage1001ALL() + public void testSubscriptionCreateALL() { String arguments = "arguments"; - _logMessage = SubscriptionMessages.SUB_1001(arguments, true, true); + _logMessage = SubscriptionMessages.SUB_CREATE(arguments, true, true); List<Object> log = performLog(); String[] expected = {"Create :", "Durable", "Arguments :", arguments}; @@ -36,9 +39,9 @@ public class SubscriptionMessagesTest extends AbstractTestMessages validateLogMessage(log, "SUB-1001", expected); } - public void testMessage1001Durable() + public void testSubscriptionCreateDurable() { - _logMessage = SubscriptionMessages.SUB_1001(null, true, false); + _logMessage = SubscriptionMessages.SUB_CREATE(null, true, false); List<Object> log = performLog(); String[] expected = {"Create :", "Durable"}; @@ -46,11 +49,11 @@ public class SubscriptionMessagesTest extends AbstractTestMessages validateLogMessage(log, "SUB-1001", expected); } - public void testMessage1001Arguments() + public void testSubscriptionCreateArguments() { String arguments = "arguments"; - _logMessage = SubscriptionMessages.SUB_1001(arguments, false, true); + _logMessage = SubscriptionMessages.SUB_CREATE(arguments, false, true); List<Object> log = performLog(); String[] expected = {"Create :","Arguments :", arguments}; @@ -59,9 +62,9 @@ public class SubscriptionMessagesTest extends AbstractTestMessages } - public void testMessage1002() + public void testSubscriptionClose() { - _logMessage = SubscriptionMessages.SUB_1002(); + _logMessage = SubscriptionMessages.SUB_CLOSE(); List<Object> log = performLog(); String[] expected = {"Close"}; @@ -69,11 +72,11 @@ public class SubscriptionMessagesTest extends AbstractTestMessages validateLogMessage(log, "SUB-1002", expected); } - public void testMessage1003() + public void testSubscriptionState() { String state = "ACTIVE"; - _logMessage = SubscriptionMessages.SUB_1003(state); + _logMessage = SubscriptionMessages.SUB_STATE(state); List<Object> log = performLog(); String[] expected = {"State :", state}; diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/VirtualHostMessagesTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/VirtualHostMessagesTest.java index 2158676115..06a8acac29 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/messages/VirtualHostMessagesTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/messages/VirtualHostMessagesTest.java @@ -22,12 +22,15 @@ package org.apache.qpid.server.logging.messages; import java.util.List; +/** + * Test VHT Log Messages + */ public class VirtualHostMessagesTest extends AbstractTestMessages { - public void testMessage1001() + public void testVirtualhostCreated() { String name = "test"; - _logMessage = VirtualHostMessages.VHT_1001(name); + _logMessage = VirtualHostMessages.VHT_CREATED(name); List<Object> log = performLog(); String[] expected = {"Created :", name}; @@ -35,9 +38,9 @@ public class VirtualHostMessagesTest extends AbstractTestMessages validateLogMessage(log, "VHT-1001", expected); } - public void testMessage1002() + public void testSubscriptionClosed() { - _logMessage = VirtualHostMessages.VHT_1002(); + _logMessage = VirtualHostMessages.VHT_CLOSED(); List<Object> log = performLog(); String[] expected = {"Closed"}; diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/AbstractTestLogSubject.java b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/AbstractTestLogSubject.java index 68f3fed1f9..905d63ea09 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/AbstractTestLogSubject.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/AbstractTestLogSubject.java @@ -42,6 +42,17 @@ import org.apache.qpid.server.protocol.AMQProtocolSession; import java.util.List; +/** + * Abstract Test for LogSubject testing + * Includes common validation code and two common tests. + * + * Each test class sets up the LogSubject and contains details of how to + * validate this class then performs a log statement with logging enabled and + * logging disabled. + * + * The resulting log file is then validated. + * + */ public abstract class AbstractTestLogSubject extends TestCase { protected Configuration _config = new PropertiesConfiguration(); diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/BindingLogSubjectTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/BindingLogSubjectTest.java index 845d02267f..6319238841 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/BindingLogSubjectTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/BindingLogSubjectTest.java @@ -27,6 +27,9 @@ import org.apache.qpid.server.queue.MockAMQQueue; import org.apache.qpid.server.registry.ApplicationRegistry; import org.apache.qpid.server.virtualhost.VirtualHost; +/** + * Validate BindingLogSubjects are logged as expected + */ public class BindingLogSubjectTest extends AbstractTestLogSubject { diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/ChannelLogSubjectTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/ChannelLogSubjectTest.java index 75f31d53d1..41760e1b05 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/ChannelLogSubjectTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/ChannelLogSubjectTest.java @@ -22,6 +22,9 @@ package org.apache.qpid.server.logging.subjects; import org.apache.qpid.server.AMQChannel; +/** + * Validate ChannelLogSubjects are logged as expected + */ public class ChannelLogSubjectTest extends ConnectionLogSubjectTest { private final int _channelID = 1; diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/ConnectionLogSubjectTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/ConnectionLogSubjectTest.java index 0eb9901757..92234e9241 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/ConnectionLogSubjectTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/ConnectionLogSubjectTest.java @@ -20,6 +20,9 @@ */ package org.apache.qpid.server.logging.subjects; +/** + * Validate ConnectionLogSubjects are logged as expected + */ public class ConnectionLogSubjectTest extends AbstractTestLogSubject { diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/ExchangeLogSubjectTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/ExchangeLogSubjectTest.java index 5bf00cc92f..7e16516fc6 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/ExchangeLogSubjectTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/ExchangeLogSubjectTest.java @@ -24,6 +24,10 @@ import org.apache.qpid.server.exchange.Exchange; import org.apache.qpid.server.registry.ApplicationRegistry; import org.apache.qpid.server.virtualhost.VirtualHost; + +/** + * Validate ExchangeLogSubjects are logged as expected + */ public class ExchangeLogSubjectTest extends AbstractTestLogSubject { Exchange _exchange; diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/MessageStoreLogSubjectTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/MessageStoreLogSubjectTest.java index 53edf98d79..9c868ea651 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/MessageStoreLogSubjectTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/MessageStoreLogSubjectTest.java @@ -23,6 +23,9 @@ package org.apache.qpid.server.logging.subjects; import org.apache.qpid.server.virtualhost.VirtualHost; import org.apache.qpid.server.registry.ApplicationRegistry; +/** + * Validate MessageStoreLogSubjects are logged as expected + */ public class MessageStoreLogSubjectTest extends AbstractTestLogSubject { VirtualHost _testVhost; diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/QueueLogSubjectTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/QueueLogSubjectTest.java index 7ef1f8d903..d46e1ee11b 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/QueueLogSubjectTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/QueueLogSubjectTest.java @@ -25,6 +25,9 @@ import org.apache.qpid.server.queue.MockAMQQueue; import org.apache.qpid.server.registry.ApplicationRegistry; import org.apache.qpid.server.virtualhost.VirtualHost; +/** + * Validate QueueLogSubjects are logged as expected + */ public class QueueLogSubjectTest extends AbstractTestLogSubject { @@ -46,14 +49,13 @@ public class QueueLogSubjectTest extends AbstractTestLogSubject /** * Validate that the logged Subject message is as expected: - * MESSAGE [Blank][vh(/test)/qu(BindingLogSubjectTest)] <Log Message> + * MESSAGE [Blank][vh(/test)/qu(QueueLogSubjectTest)] <Log Message> * * @param message the message whos format needs validation */ @Override protected void validateLogStatement(String message) { - System.err.println(message); verifyVirtualHost(message, _testVhost); verifyQueue(message, _queue); } diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/SubscriptionLogSubjectTest.java b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/SubscriptionLogSubjectTest.java index fda951616e..e96dc47367 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/SubscriptionLogSubjectTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/SubscriptionLogSubjectTest.java @@ -21,7 +21,6 @@ package org.apache.qpid.server.logging.subjects; import org.apache.qpid.framing.AMQShortString; -import org.apache.qpid.framing.FieldTable; import org.apache.qpid.server.AMQChannel; import org.apache.qpid.server.flow.LimitlessCreditManager; import org.apache.qpid.server.queue.AMQQueue; @@ -32,14 +31,14 @@ import org.apache.qpid.server.subscription.SubscriptionFactory; import org.apache.qpid.server.subscription.SubscriptionFactoryImpl; import org.apache.qpid.server.virtualhost.VirtualHost; +/** + * Validate SubscriptionLogSubjects are logged as expected + */ public class SubscriptionLogSubjectTest extends AbstractTestLogSubject { AMQQueue _queue; VirtualHost _testVhost; - private boolean _acks; - private FieldTable _filters; - private boolean _noLocal; private int _channelID = 1; Subscription _subscription; @@ -50,7 +49,7 @@ public class SubscriptionLogSubjectTest extends AbstractTestLogSubject _testVhost = ApplicationRegistry.getInstance().getVirtualHostRegistry(). getVirtualHost("test"); - _queue = new MockAMQQueue("QueueLogSubjectTest"); + _queue = new MockAMQQueue("SubscriptionLogSubjectTest"); ((MockAMQQueue) _queue).setVirtualHost(_testVhost); AMQChannel channel = new AMQChannel(_session, _channelID, _session.getVirtualHost().getMessageStore()); @@ -60,7 +59,7 @@ public class SubscriptionLogSubjectTest extends AbstractTestLogSubject SubscriptionFactory factory = new SubscriptionFactoryImpl(); _subscription = factory.createSubscription(_channelID, _session, new AMQShortString("cTag"), - _acks, _filters, _noLocal, + false, null, false, new LimitlessCreditManager()); _subscription.setQueue(_queue, false); @@ -70,7 +69,7 @@ public class SubscriptionLogSubjectTest extends AbstractTestLogSubject /** * Validate that the logged Subject message is as expected: - * MESSAGE [Blank][sub:0(qu(QueueLogSubjectTest))] <Log Message> + * MESSAGE [Blank][sub:0(vh(/test)/qu(SubscriptionLogSubjectTest))] <Log Message> * * @param message the message whos format needs validation */ @@ -84,9 +83,23 @@ public class SubscriptionLogSubjectTest extends AbstractTestLogSubject assertNotNull("Unable to locate subscription 'sub:" + _subscription.getSubscriptionID() + "'"); + + + // Pull out the qu(..) section from the subscription message + // Split it into three parts + // MESSAGE [Blank][sub:0(vh(/ + // test)/ + // qu(SubscriptionLogSubjectTest))] + // Take the last bit and drop off the extra )] + String[] parts = message.split("/"); + assertEquals("Message part count wrong", 3, parts.length); + String subscription = parts[2].substring(0, parts[2].indexOf(")") + 1); + // Adding the ')' is a bit ugly but SubscriptionLogSubject is the only // Subject that nests () and so the simple parser of checking for the // next ')' falls down. - verifyQueue(subscriptionSlice + ")", _queue); + verifyVirtualHost(subscriptionSlice+ ")", _queue.getVirtualHost()); + + verifyQueue(subscription, _queue); } } diff --git a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/TestBlankSubject.java b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/TestBlankSubject.java index 9e3c6f9bcb..3028ad0409 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/TestBlankSubject.java +++ b/java/broker/src/test/java/org/apache/qpid/server/logging/subjects/TestBlankSubject.java @@ -20,6 +20,9 @@ */ package org.apache.qpid.server.logging.subjects; +/** + * Blank Subject for testing + */ public class TestBlankSubject extends AbstractLogSubject { public TestBlankSubject() diff --git a/java/broker/src/velocity/java/org/apache/qpid/server/logging/GenerateLogMessages.java b/java/broker/src/velocity/java/org/apache/qpid/server/logging/GenerateLogMessages.java index 2efb22610f..738d54f8f4 100644 --- a/java/broker/src/velocity/java/org/apache/qpid/server/logging/GenerateLogMessages.java +++ b/java/broker/src/velocity/java/org/apache/qpid/server/logging/GenerateLogMessages.java @@ -261,7 +261,7 @@ public class GenerateLogMessages if (message.startsWith(messageKey)) { // Method names can't have a '-' in them so lets make it '_' - // e.g. BRK_1001 + // e.g. BRK-STARTUP -> BRK_STARTUP logEntryData.put("methodName", message.replace('-', '_')); // Store the real name so we can use that in the actual log. logEntryData.put("name", message); diff --git a/java/broker/src/velocity/templates/org/apache/qpid/server/logging/messages/LogMessages.vm b/java/broker/src/velocity/templates/org/apache/qpid/server/logging/messages/LogMessages.vm index fecc9a787e..4eda0ffb19 100644 --- a/java/broker/src/velocity/templates/org/apache/qpid/server/logging/messages/LogMessages.vm +++ b/java/broker/src/velocity/templates/org/apache/qpid/server/logging/messages/LogMessages.vm @@ -121,7 +121,7 @@ public class ${type.name}Messages public static LogMessage ${message.methodName}(#foreach($parameter in ${message.parameters})${parameter.type} ${parameter.name}#if (${velocityCount} != ${message.parameters.size()} ), #end #end#if(${message.parameters.size()} > 0 && ${message.options.size()} > 0), #end#foreach($option in ${message.options})boolean ${option.name}#if (${velocityCount} != ${message.options.size()} ), #end#end) { - String rawMessage = "${message.name} : " + _messages.getString("${message.name}"); + String rawMessage = _messages.getString("${message.name}"); ## If we have some options then we need to build the message based ## on those values so only provide that logic if we need it. #if(${message.options.size()} > 0) diff --git a/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java b/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java index 2d9ce35d29..c4c38e0ece 100644 --- a/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java +++ b/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java @@ -24,7 +24,6 @@ import org.apache.log4j.Logger; import org.apache.qpid.client.AMQSession; import org.apache.qpid.client.AMQQueue; import org.apache.qpid.client.AMQDestination; -import org.apache.qpid.test.utils.QpidTestCase; import org.apache.qpid.AMQException; import org.apache.qpid.server.logging.AbstractTestLogging; import org.apache.qpid.framing.AMQShortString; @@ -152,7 +151,7 @@ public class ProducerFlowControlTest extends AbstractTestLogging results = _monitor.findMatches("QUE-1004"); - assertEquals("Did not find correct number of QUE_1004 queue underfull messages", 1, results.size()); + assertEquals("Did not find correct number of QUE_UNDERFULL queue underfull messages", 1, results.size()); |