...
Additions to existing classes
The following classes will have logging added to provide the required log messages specified in the Functional Specification.
Main
| No Format |
|---|
BRK-1001 : Startup : Version: <Version> Build: <Build>
BRK-1004 : Ready
BRK-1007 : Using logging configuration : <path>
|
ApplicationRegistry
| No Format |
|---|
BRK-1002 : Starting : Listening on <Transport> port <Port>
BRK-1003 : Shuting down : <Transport> port <Port>
BRK-1005 : Stopped
|
ConfigurationFileApplicationRegistry
| No Format |
|---|
BRK-1006 : Using configuration : <path>
|
JMXManagedObjectRegistry
| No Format |
|---|
MNG-1001 : Startup
MNG-1002 : Starting : <service> : Listening on port <Port>
MNG-1003 : Shuting down : <service> : port <Port>
MNG-1004 : Ready
MNG-1005 : Stopped
MNG-1006 : Using SSL Keystore : <path>
|
VirtualHost
| No Format |
|---|
VHT-1001 : Created : <name>
VHT-1002 : Closed
|
DerbyMessageStore/MemoryMessageStore
| No Format |
|---|
MST-1001 : Created : <name>
MST-1003 : Closed
|
DerbyMessageStore
| No Format |
|---|
MST-1002 : Store location : <path>
MST-1004 : Recovery Start [: <queue.name>]
MST-1005 : Recovered <count> messages for queue <queue.name>
MST-1006 : Recovery Complete [: <queue.name>]
|
AMQMinaProtocolSession
| No Format |
|---|
CON-1001 : Open : Client ID <id> : Protocol Version : <version>
CON-1002 : Close
|
AMQChannel
| No Format |
|---|
CHN-1001 : Create : Prefetch <count>
CHN-1002 : Flow <value>
CHN-1003 : Close
|
QueueRegistry
| No Format |
|---|
QUE-1001 : Create : [AutoDelete] [Durable|Transient] [Priority:<levels>] Owner:<name>
QUE-1002 : Deleted
|
AbstractExchange
| No Format |
|---|
EXH-1001 : Create : [Durable] Type:<value> Name:<value>
EXH-1002 : Deleted
|
ExchangeBindings
| No Format |
|---|
BND-1001 : Create [: Arguments : <key=value>]
BND-1002 : Deleted
|
SubscriptionImpl
| No Format |
|---|
SUB-1001 : Create : [Durable] [Arguments : <key=value>]
SUB-1002 : Close
|
Deletions from existing classes
The following log statements should be removed from the broker packages as they are being replaced with a new message.
SimpleAMQQueue
_logger.info("Auto-deleteing queue:" + this);
JMXManagedObjectRegistry
log.info("Initialising managed object registry using platform MBean server");
_log.info("JMX ConnectorServer using SSL keystore file " + ksf.getAbsolutePath());
_startupLog.info("JMX ConnectorServer using SSL keystore file " + ksf.getAbsolutePath());
DerbyMessageStore.java:
_logger.info("Configuring Derby message store for virtual host " + virtualHost.getName());
_logger.info("Recovering persistent state...");
_logger.info("Persistent state recovered successfully");
_logger.info("Recovering durable exchange " + exchange.getName() + " of type " + exchange.getType() + "...");
_logger.info("Restoring binding: (Exchange: " + exchange.getName() + ", Queue: " + queueName
_logger.info("Recovered message counts: " + queueRecoveries);
MemoryMessageStore.java:
_log.info("Using capacity " + DEFAULT_HASHTABLE_CAPACITY + " for hash tables");
_log.info("Using capacity " + hashtableCapacity + " for hash tables");
VirtualHost.java _logger.info("Binding queue:" + queue + " with routing key '" + routingKey + "' to exchange:" + this);
src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java: _logger.info("Channel" + channelId + " awaiting closure - processing close-ok");
src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java: _logger.info("Closing channel due to: " + e.getMessage());
src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java: _logger.info("Closing connection due to: " + e.getMessage());
src/main/java/org/apache/qpid/server/protocol/AMQMinaProtosrc/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java: _logger.info("Auto-deleteing queue:" + this);
src/main/java/org/apache/qpid/server/management/NoopManagedObjectRegistry.java: _log.info("Management is disabled");
src/main/java/org/apache/qpid/server/management/JMXManagedObjectRegistry.java: _log.info("Initialising managed object registry using platform MBean server");
src/main/java/org/apache/qpid/server/management/JMXManagedObjectRegistry.java: _log.info("JMX ConnectorServer using SSL keystore file " + ksf.getAbsolutePath());
src/main/java/org/apache/qpid/server/management/JMXManagedObjectRegistry.java: _startupLog.info("JMX ConnectorServer using SSL keystore file " + ksf.getAbsolutePath());
src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java: _logger.info("Configuring Derby message store for virtual host " + virtualHost.getName());
src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java: _logger.info("Recovering persistent state...");
src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java: _logger.info("Persistent state recovered successfully");
src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java: _logger.info("Recovering durable exchange " + exchange.getName() + " of type " + exchange.getType() + "...");
src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java: _logger.info("Restoring binding: (Exchange: " + exchange.getName() + ", Queue: " + queueName
src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java: _logger.info("Recovered message counts: " + queueRecoveries);
src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java: _log.info("Using capacity " + DEFAULT_HASHTABLE_CAPACITY + " for hash tables");
src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java: _log.info("Using capacity " + hashtableCapacity + " for hash tables");
src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java: _logger.info("Binding queue:" + queue + " with routing key '" + routingKey + "' to exchange:" + this);
src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java: _logger.info("Channel" + channelId + " awaiting closure - processing close-ok");
src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java: _logger.info("Closing channel due to: " + e.getMessage());
src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java: _logger.info("Closing connection due to: " + e.getMessage());
src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java: _logger.info("Closing connection due to: " + e.getMessage());
src/main/java/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java: _logger.info("Protocol session created for:" + protocolSession.getRemoteAddress());
src/main/java/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java: _logger.info("Session opened for:" + protocolSession.getRemoteAddress());
src/main/java/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java: _logger.info("Protocol Session closed for:" + protocolSession.getRemoteAddress());
src/main/java/org/apache/qpid/server/subscription/SubscriptionImpl.java: _logger.info("Closing subscription (" + debugIdentity() + "):" + this);
src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java: _logger.info("Authentication failed:" + (cause == null ? "" : cause.getMessage()));
src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java: _logger.info("Connected as: " + ss.getAuthorizationID());
src/main/java/org/apache/qpid/server/handler/ConnectionSecureOkMethodHandler.java: _logger.info("Authentication failed:" + (cause == null ? "" : cause.getMessage()));
src/main/java/org/apache/qpid/server/handler/ConnectionSecureOkMethodHandler.java: _logger.info("Connected as: " + ss.getAuthorizationID());
src/main/java/org/apache/qpid/server/handler/QueueUnbindHandler.java: _log.info("Binding queue " + queue + " to exchange " + exch + " with routing key " + routingKey);
src/main/java/org/apache/qpid/server/handler/ConnectionCloseMethodHandler.java: _logger.info("ConnectionClose received with reply code/reply text " + body.getReplyCode() + "/" +
src/main/java/org/apache/qpid/server/handler/QueueBindHandler.java: _log.info("Binding queue " + queue + " to exchange " + exch + " with routing key " + routingKey);
src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java: _logger.info("Queue " + queueName + " bound to default exchange(" + defaultExchange.getName() + ")");
src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java: _logger.info("Queue " + queueName + " declared successfully");
src/main/java/org/apache/qpid/server/Main.java: _brokerLogger.info("Starting Qpid Broker " + QpidProperties.getReleaseVersion()
src/main/java/org/apache/qpid/server/Main.java: _brokerLogger.info("Qpid.AMQP listening on non-SSL address " + bindAddress);
src/main/java/org/apache/qpid/server/Main.java: _brokerLogger.info("Qpid.AMQP listening on SSL port " + config.getSSLPort());
src/main/java/org/apache/qpid/server/Main.java: _brokerLogger.info("Qpid Broker Ready :" + QpidProperties.getReleaseVersion()
src/main/java/org/apache/qpid/configuration/Configuration.java:// _devlog.info("Configuring logger using configuration file " + logConfigFile.getAbsolutePath());
src/main/java/org/apache/qpid/configuration/Configuration.java:// _devlog.info("log file " + logConfigFile.getAbsolutePath() + " will be checked for changes every "
colSession.java: _logger.info("Closing connection due to: " + e.getMessage());
src/main/java/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java: _logger.info("Protocol session created for:" + protocolSession.getRemoteAddress());
src/main/java/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java: _logger.info("Session opened for:" + protocolSession.getRemoteAddress());
src/main/java/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java: _logger.info("Protocol Session closed for:" + protocolSession.getRemoteAddress());
src/main/java/org/apache/qpid/server/subscription/SubscriptionImpl.java: _logger.info("Closing subscription (" + debugIdentity() + "):" + this);
src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java: _logger.info("Authentication failed:" + (cause == null ? "" : cause.getMessage()));
src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java: _logger.info("Connected as: " + ss.getAuthorizationID());
src/main/java/org/apache/qpid/server/handler/ConnectionSecureOkMethodHandler.java: _logger.info("Authentication failed:" + (cause == null ? "" : cause.getMessage()));
src/main/java/org/apache/qpid/server/handler/ConnectionSecureOkMethodHandler.java: _logger.info("Connected as: " + ss.getAuthorizationID());
src/main/java/org/apache/qpid/server/handler/QueueUnbindHandler.java: _log.info("Binding queue " + queue + " to exchange " + exch + " with routing key " + routingKey);
src/main/java/org/apache/qpid/server/handler/ConnectionCloseMethodHandler.java: _logger.info("ConnectionClose received with reply code/reply text " + body.getReplyCode() + "/" +
src/main/java/org/apache/qpid/server/handler/QueueBindHandler.java: _log.info("Binding queue " + queue + " to exchange " + exch + " with routing key " + routingKey);
src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java: _logger.info("Queue " + queueName + " bound to default exchange(" + defaultExchange.getName() + ")");
src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java: _logger.info("Queue " + queueName + " declared successfully");
src/main/java/org/apache/qpid/server/Main.java: _brokerLogger.info("Starting Qpid Broker " + QpidProperties.getReleaseVersion()
src/main/java/org/apache/qpid/server/Main.java: _brokerLogger.info("Qpid.AMQP listening on non-SSL address " + bindAddress);
src/main/java/org/apache/qpid/server/Main.java: _brokerLogger.info("Qpid.AMQP listening on SSL port " + config.getSSLPort());
src/main/java/org/apache/qpid/server/Main.java: _brokerLogger.info("Qpid Broker Ready :" + QpidProperties.getReleaseVersion()
src/main/java/org/apache/qpid/configuration/Configuration.java:// _devlog.info("Configuring logger using configuration file " + logConfigFile.getAbsolutePath());
src/main/java/org/apache/qpid/configuration/Configuration.java:// _devlog.info("log file " + logConfigFile.getAbsolutePath() + " will be checked for changes every "