Changeset 49 for trunk/src/main/java/omq/common/broker/Broker.java

Timestamp:

06/19/13 15:59:53 (11 years ago)

Author:

stoda

Message:

log4j added

File:

• trunk/src/main/java/omq/common/broker/Broker.java (modified) (7 diffs)

trunk/src/main/java/omq/common/broker/Broker.java

@@ -2 +2 @@
 
 import java.io.IOException;
+import java.net.URL;
 import java.util.HashMap;
 import java.util.Map;
@@ -20 +21 @@
 import omq.server.RemoteObject;
 
+import org.apache.log4j.Logger;
+import org.apache.log4j.xml.DOMConfigurator;
+
 import com.rabbitmq.client.Channel;
 import com.rabbitmq.client.Connection;
@@ -28 +32 @@
 
 public class Broker {
+
+        private static final Logger logger = Logger.getLogger(Broker.class.getName());
+
         private static Connection connection;
         private static Channel channel;
@@ -45 +52 @@
         public static synchronized void initBroker(Properties env) throws Exception {
                 if (environment == null) {
+
+                        // Load log4j configuration
+                        URL log4jResource = Broker.class.getResource("/log4j.xml");
+                        DOMConfigurator.configure(log4jResource);
+
                         remoteObjs = new HashMap<String, RemoteObject>();
                         environment = env;
@@ -58 +70 @@
                         }
                 } else {
-                        throw new InitBrokerException("Broker already started");
+                        logger.error("Broker is already started");
+                        throw new InitBrokerException("Broker is already started");
                 }
         }
 
         public static void stopBroker() throws Exception {
+                logger.warn("Stopping broker");
                 // Stop the client
                 if (clientStarted) {
@@ -93 +107 @@
 
         public static void closeConnection() throws IOException {
+                logger.warn("Clossing connection");
                 connectionClosed = true;
                 connection.close();
@@ -241 +256 @@
                         @Override
                         public void shutdownCompleted(ShutdownSignalException cause) {
+                                logger.warn("Shutdown message received. Cause: " + cause.getMessage());
                                 if (!connectionClosed)
                                         if (cause.isHardError()) {