Updated Branches: refs/heads/trunk 0214bfbfc -> 59af7479b
Polished the logging Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/59af7479 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/59af7479 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/59af7479 Branch: refs/heads/trunk Commit: 59af7479b21017d254158f0c6858a5aaaf2362f7 Parents: 0214bfb Author: Claus Ibsen <[email protected]> Authored: Fri Oct 11 11:20:22 2013 +0200 Committer: Claus Ibsen <[email protected]> Committed: Fri Oct 11 11:20:22 2013 +0200 ---------------------------------------------------------------------- .../java/org/apache/activemq/broker/TransportConnector.java | 4 ++-- .../java/org/apache/activemq/network/NetworkConnector.java | 4 ++-- .../java/org/apache/activemq/network/jms/JmsConnector.java | 6 +++--- .../main/java/org/apache/activemq/proxy/ProxyConnector.java | 4 ++-- .../apache/activemq/leveldb/test/ElectingLevelDBStoreTest.java | 2 +- .../activemq/partition/ZooKeeperPartitionBrokerTest.java | 2 +- 6 files changed, 11 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/59af7479/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java ---------------------------------------------------------------------- diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java b/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java index fff5212..4e31ee0 100755 --- a/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java +++ b/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java @@ -252,7 +252,7 @@ public class TransportConnector implements Connector, BrokerServiceAware { this.statusDector.start(); } - LOG.info("Connector {} Started", getName()); + LOG.info("Connector {} started", getName()); } public String getPublishableConnectString() throws Exception { @@ -283,7 +283,7 @@ public class TransportConnector implements Connector, BrokerServiceAware { } server = null; ss.throwFirstException(); - LOG.info("Connector {} Stopped", getName()); + LOG.info("Connector {} stopped", getName()); } // Implementation methods http://git-wip-us.apache.org/repos/asf/activemq/blob/59af7479/activemq-broker/src/main/java/org/apache/activemq/network/NetworkConnector.java ---------------------------------------------------------------------- diff --git a/activemq-broker/src/main/java/org/apache/activemq/network/NetworkConnector.java b/activemq-broker/src/main/java/org/apache/activemq/network/NetworkConnector.java index ffce8b8..3cee7a4 100644 --- a/activemq-broker/src/main/java/org/apache/activemq/network/NetworkConnector.java +++ b/activemq-broker/src/main/java/org/apache/activemq/network/NetworkConnector.java @@ -168,11 +168,11 @@ public abstract class NetworkConnector extends NetworkBridgeConfiguration implem if (localURI == null) { throw new IllegalStateException("You must configure the 'localURI' property"); } - LOG.info("Network Connector {} Started", this); + LOG.info("Network Connector {} started", this); } protected void handleStop(ServiceStopper stopper) throws Exception { - LOG.info("Network Connector {} Stopped", this); + LOG.info("Network Connector {} stopped", this); } public boolean isStarted() { http://git-wip-us.apache.org/repos/asf/activemq/blob/59af7479/activemq-broker/src/main/java/org/apache/activemq/network/jms/JmsConnector.java ---------------------------------------------------------------------- diff --git a/activemq-broker/src/main/java/org/apache/activemq/network/jms/JmsConnector.java b/activemq-broker/src/main/java/org/apache/activemq/network/jms/JmsConnector.java index f8f602b..afeb88a 100755 --- a/activemq-broker/src/main/java/org/apache/activemq/network/jms/JmsConnector.java +++ b/activemq-broker/src/main/java/org/apache/activemq/network/jms/JmsConnector.java @@ -91,7 +91,7 @@ public abstract class JmsConnector implements Service { bridge.stop(); LOG.info("Expired bridge: {}", bridge); } catch (Exception e) { - LOG.warn("stopping expired bridge {} caused an exception", bridge, e); + LOG.warn("Stopping expired bridge {} caused an exception", bridge, e); } } return false; @@ -160,7 +160,7 @@ public abstract class JmsConnector implements Service { for (DestinationBridge bridge : outboundBridges) { bridge.start(); } - LOG.info("JMS Connector {} Started", getName()); + LOG.info("JMS Connector {} started", getName()); } } @@ -176,7 +176,7 @@ public abstract class JmsConnector implements Service { for (DestinationBridge bridge : outboundBridges) { bridge.stop(); } - LOG.info("JMS Connector {} Stopped", getName()); + LOG.info("JMS Connector {} stopped", getName()); } } http://git-wip-us.apache.org/repos/asf/activemq/blob/59af7479/activemq-broker/src/main/java/org/apache/activemq/proxy/ProxyConnector.java ---------------------------------------------------------------------- diff --git a/activemq-broker/src/main/java/org/apache/activemq/proxy/ProxyConnector.java b/activemq-broker/src/main/java/org/apache/activemq/proxy/ProxyConnector.java index bf10bfe..d82911b 100644 --- a/activemq-broker/src/main/java/org/apache/activemq/proxy/ProxyConnector.java +++ b/activemq-broker/src/main/java/org/apache/activemq/proxy/ProxyConnector.java @@ -71,7 +71,7 @@ public class ProxyConnector implements Service { } }); getServer().start(); - LOG.info("Proxy Connector {} Started", getName()); + LOG.info("Proxy Connector {} started", getName()); } @@ -85,7 +85,7 @@ public class ProxyConnector implements Service { ss.stop(iter.next()); } ss.throwFirstException(); - LOG.info("Proxy Connector {} Stopped", getName()); + LOG.info("Proxy Connector {} stopped", getName()); } // Properties http://git-wip-us.apache.org/repos/asf/activemq/blob/59af7479/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/ElectingLevelDBStoreTest.java ---------------------------------------------------------------------- diff --git a/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/ElectingLevelDBStoreTest.java b/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/ElectingLevelDBStoreTest.java index 93bf051..f3c1581 100644 --- a/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/ElectingLevelDBStoreTest.java +++ b/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/ElectingLevelDBStoreTest.java @@ -64,7 +64,7 @@ public class ElectingLevelDBStoreTest { connector = new NIOServerCnxnFactory(); connector.configure(new InetSocketAddress(0), 100); connector.startup(zk_server); - System.out.println("ZooKeeper Started"); + System.out.println("ZooKeeper started"); } @After http://git-wip-us.apache.org/repos/asf/activemq/blob/59af7479/activemq-partition/src/test/java/org/apache/activemq/partition/ZooKeeperPartitionBrokerTest.java ---------------------------------------------------------------------- diff --git a/activemq-partition/src/test/java/org/apache/activemq/partition/ZooKeeperPartitionBrokerTest.java b/activemq-partition/src/test/java/org/apache/activemq/partition/ZooKeeperPartitionBrokerTest.java index 45193bb..8c64e81 100644 --- a/activemq-partition/src/test/java/org/apache/activemq/partition/ZooKeeperPartitionBrokerTest.java +++ b/activemq-partition/src/test/java/org/apache/activemq/partition/ZooKeeperPartitionBrokerTest.java @@ -45,7 +45,7 @@ public class ZooKeeperPartitionBrokerTest extends PartitionBrokerTest { connector = new NIOServerCnxnFactory(); connector.configure(new InetSocketAddress(0), 100); connector.startup(zk_server); - System.out.println("ZooKeeper Started"); + System.out.println("ZooKeeper started"); super.setUp(); }
