...
The following log statements should be removed from the broker packages as they are being replaced with a new message.
SimpleAMQQueue
| No Format |
|---|
_logger.info("Auto-deleteing queue:" + this);
|
JMXManagedObjectRegistry
| No Format |
|---|
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
...
| No Format |
|---|
_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);
_logger.debug("public void createQueue(AMQQueue queue = " + queue + "): called");
_logger.debug("public void removeQueue(AMQShortString name = " + name + "): called");
_logger.debug("On recovery, delivering " + message.getMessageId() + " to " + queue.getName());
|
MemoryMessageStore
...
| No Format |
|---|
_log.info("Using capacity " + DEFAULT_HASHTABLE_CAPACITY + " for hash tables"); |
...
_log.info("Using capacity " + hashtableCapacity + " for hash tables");
|
VirtualHost
...
| No Format |
|---|
_logger.info("Binding queue:" + queue + " with routing key '" + routingKey + "' to exchange:" + this);
_logger.debug("Loading configuration for virtualhost: " + config.getName());
|
AMQMinaProtocolSession.java:
| No Format |
|---|
_logger.info("Channel[" + channelId + "] awaiting closure - processing close-ok"); |
...
_logger.info("Closing channel due to: " + e.getMessage()); |
...
_logger.info("Closing connection due to: " + e.getMessage()); |
...
_logger.info("Closing connection due to: " + e.getMessage());
_logger.debug("REALLY Closing protocol session:" + _minaProtocolSession);
|
AMQPFastProtocolHandler
| No Format |
|---|
_logger.info("Protocol session created for:" + protocolSession.getRemoteAddress()); |
...
_logger.info("Session opened for:" + protocolSession.getRemoteAddress()); |
...
_logger.info("Protocol Session closed for:" + protocolSession.getRemoteAddress());
_logger.debug("AMQPFastProtocolHandler created");
|
SubscriptionImpl
| No Format |
|---|
_logger.info("Closing subscription (" + debugIdentity() + "):" + this);
|
QueueUnbindHandler
| No Format |
|---|
_log.info("Binding queue " + queue + " to exchange " + exch + " with routing key " + routingKey);
|
ConnectionCloseMethodHandler
| No Format |
|---|
_logger.info("ConnectionClose received with reply code/reply text " + body. |
...
...
QueueBindHandler
| No Format |
|---|
_log.info("Binding queue " + queue + " to exchange " + exch + " with routing key " + routingKey);
|
QueueDeclareHandler
| No Format |
|---|
_logger.info("Queue " + queueName + " bound to default exchange(" + defaultExchange.getName() + ")"); |
...
_logger.info("Queue " + queueName + " declared successfully");
|
Main
| No Format |
|---|
h4. Main
_brokerLogger.info("Starting Qpid Broker " + QpidProperties.getReleaseVersion() |
...
_brokerLogger.info("Qpid.AMQP listening on non-SSL address " + bindAddress); |
...
_brokerLogger.info("Qpid.AMQP listening on SSL port " + config.getSSLPort()); |
...
_brokerLogger.info("Qpid Broker Ready :" + QpidProperties.getReleaseVersion()
|
Configuration
| No Format |
|---|
h4. Configuration
|
...
_devlog.info("Configuring logger using configuration file " + logConfigFile.getAbsolutePath());
_devlog.info("log file " + logConfigFile.getAbsolutePath() + " will be checked for changes every
_devlog.debug("Using configuration file " + _configFile.getAbsolutePath());
ex.getMessage());
|
...
ChannelFlowHandler.java:
| No Format |
|---|
_logger.debug("Channel.Flow for channel " + channelId + ", active=" + body.getActive());
|
BasicConsumeMethodHandler
| No Format |
|---|
_logger.debug("BasicConsume: from '" + body.getQueue() +
_logger.debug("No queue for '" + body.getQueue() + "'");
_logger.debug("Closing connection due to invalid selector");
|
| No Format |
|---|
_logger.debug("Exchange " + getName() + ": Unbinding " + queue.getName());
_logger.debug("Exchange " + getName() + ": routing message with headers " + headers);
|
noformat |