...
The following log statements should be removed from the broker packages as they are being replaced with a new message.
...
AMQMinaProtocolSession
| No Format |
|---|
_logger.info("Auto-deleteing queue"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:" + this_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");
|
BasicConsumeMethodHandler
| No Format |
|---|
_logger.debug("BasicConsume: from '" + body.getQueue() +
_logger.debug("No queue for '" + body.getQueue() + "'");
_logger.debug("Closing connection due to invalid selector");
|
ChannelFlowHandler.java:
| No Format |
|---|
_logger.debug("Channel.Flow for channel " + channelId + ", active=" + body.getActive());
|
Configuration
| No Format |
|---|
_devlog.info("Configuring logger using configuration
log.info("Initialising managed object registry using platform MBean server");
_log.info("JMX ConnectorServer using SSL keystore file " + ksflogConfigFile.getAbsolutePath());
_startupLogdevlog.info("JMX ConnectorServer using SSL keystore"log file " + logConfigFile.getAbsolutePath() + " will be checked for changes every
_devlog.debug("Using configuration file " + ksf.getAbsolutePath()_configFile.getAbsolutePath());
ex.getMessage());
|
ConnectionCloseMethodHandler
| No Format |
|---|
_logger.info("ConnectionClose received with reply code/reply text " + body.getReplyText() + " for " + session);
|
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());
|
...
| No Format |
|---|
_loglogger.infodebug("Using capacityExchange " + DEFAULT_HASHTABLE_CAPACITYgetName() + " for hash tables");
_log.info("Using capacity : Unbinding " + hashtableCapacity + " for hash tables"queue.getName());
|
VirtualHost
| No Format |
|---|
_logger.infodebug("Binding queue:" + queue + " with routing key '" + routingKeyExchange " + getName() + "' to exchange:" + this);
_logger.debug("Loading configuration for virtualhost: routing message with headers " + config.getName()headers);
|
...
JMXManagedObjectRegistry
| No Format |
|---|
_loggerlog.info("Channel["Initialising +managed channelIdobject +registry "]using awaitingplatform closure - processing close-okMBean server");
_loggerlog.info("Closing channel due to:JMX ConnectorServer using SSL keystore file " + eksf.getMessagegetAbsolutePath());
_loggerstartupLog.info("ClosingJMX connectionConnectorServer dueusing to:SSL " + e.getMessage());
_logger.info("Closing connection due to: keystore file " + eksf.getMessagegetAbsolutePath());
_logger.debug("REALLY Closing protocol session:" + _minaProtocolSession);
|
...
Main
| No Format |
|---|
_loggerbrokerLogger.info("ProtocolStarting sessionQpid createdBroker for:" + protocolSessionQpidProperties.getRemoteAddressgetReleaseVersion());
_loggerbrokerLogger.info("Session opened for:Qpid.AMQP listening on non-SSL address " + protocolSession.getRemoteAddress()bindAddress);
_loggerbrokerLogger.info("Protocol Session closed for:Qpid.AMQP listening on SSL port " + protocolSessionconfig.getRemoteAddressgetSSLPort());
_logger.debug("AMQPFastProtocolHandler created");
|
SubscriptionImpl
| No Format |
|---|
_loggerbrokerLogger.info("ClosingQpid subscription (" + debugIdentity() + ")Broker Ready :" + thisQpidProperties.getReleaseVersion();
|
...
MemoryMessageStore
| No Format |
|---|
_log.info("BindingUsing queuecapacity " + queueDEFAULT_HASHTABLE_CAPACITY + " tofor exchange " + exch + " with routing key " + routingKeyhash tables");
|
ConnectionCloseMethodHandler
| No Format |
|---|
_logger_log.info("ConnectionCloseUsing received with reply code/reply text capacity " + body.getReplyText()hashtableCapacity + " for " + sessionhash tables");
|
QueueBindHandler
| No Format |
|---|
_log.info("Binding queue " + queue + " to exchange " + exch + " with routing key " + routingKey);
|
...
| No Format |
|---|
_logger.info("Queue " + queueName + " bound to default exchange(" + defaultExchange.getName() + ")");
_logger.info("Queue " + queueName + " declared successfully");
|
...
QueueUnbindHandler
| No Format |
|---|
_brokerLoggerlog.info("StartingBinding Qpid Brokerqueue " + QpidProperties.getReleaseVersion()
_brokerLogger.info("Qpid.AMQP listening on non-SSL addressqueue + " to exchange " + bindAddress);
_brokerLogger.info("Qpid.AMQP listening on SSL port " + config.getSSLPort());
_brokerLogger.info("Qpid Broker Ready :exch + " with routing key " + QpidProperties.getReleaseVersion(routingKey);
|
...
SimpleAMQQueue
| No Format |
|---|
_devlog.info("Configuring logger using configuration file " + logConfigFile.getAbsolutePath());
_devlog.info("log file Auto-deleteing queue:" + logConfigFile.getAbsolutePath() + " will be checked for changes every
_devlog.debug("Using configuration file " + _configFile.getAbsolutePath());
ex.getMessage());
|
...
SubscriptionImpl
| No Format |
|---|
_logger.debuginfo("Channel.FlowClosing forsubscription channel (" + channelIddebugIdentity() + ", active=):" + body.getActive(this));
|
...
VirtualHost
| No Format |
|---|
_logger.debuginfo("BasicConsume: from 'Binding queue:" + body.getQueue()queue +
_logger.debug("No queue for " with routing key '" + body.getQueue()routingKey + "'");
_logger.debug("Closing connection due to invalid selector");
|
| No Format |
|---|
to exchange:" + this);
_logger.debug("ExchangeLoading "configuration + getName() + ": Unbindingfor virtualhost: " + queue.getName());
_logger.debug("Exchange " + getName() + ": routing message with headers " + headersconfig.getName());
|