Page History

...

VirtualHost.java _logger.info("Binding queue:" + queue + " with routing key '" + routingKey + "' to exchange:" + this);

...

AMQMinaProtocolSession.java

...

:

...

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:

AMQPFastProtocolHandler

_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:

SubscriptionImpl

_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: _

QueueUnbindHandler

_log.info("Binding queue " + queue + " to exchange " + exch + " with routing key " + routingKey);

ConnectionCloseMethodHandler

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:

QueueBindHandler

_log.info("Binding queue " + queue + " to exchange " + exch + " with routing key " + routingKey);

QueueDeclareHandler

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:

h4. Main

_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()

h4. Configuration            

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 "