Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Polished the logging

This commit is contained in:
Claus Ibsen 2013-10-11 11:20:22 +02:00
parent 0214bfbfcd
commit 59af7479b2
6 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java
View File

@ -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

4
activemq-broker/src/main/java/org/apache/activemq/network/NetworkConnector.java
View File

@ -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() {

6
activemq-broker/src/main/java/org/apache/activemq/network/jms/JmsConnector.java
View File

@ -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());
}
}

4
activemq-broker/src/main/java/org/apache/activemq/proxy/ProxyConnector.java
View File

@ -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

2
activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/ElectingLevelDBStoreTest.java
View File

@ -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

2
activemq-partition/src/test/java/org/apache/activemq/partition/ZooKeeperPartitionBrokerTest.java
View File

@ -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();
}