Changeset 49 for trunk/src/main/java/omq/server/RemoteObject.java

Timestamp:

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

Author:

stoda

Message:

log4j added

File:

• trunk/src/main/java/omq/server/RemoteObject.java (modified) (7 diffs)

trunk/src/main/java/omq/server/RemoteObject.java

@@ -10 +10 @@
 import java.util.Properties;
 
+import org.apache.log4j.Logger;
+
 import omq.Remote;
 import omq.common.broker.Broker;
@@ -33 +35 @@
 
         private static final long serialVersionUID = -1778953938739846450L;
+        private static final Logger logger = Logger.getLogger(RemoteObject.class.getName());
 
         private String UID;
@@ -85 +88 @@
                         try {
                                 Delivery delivery = consumer.nextDelivery();
-                                System.out.println("RemoteObject: " + UID + " has received a message");
+
+                                logger.debug(UID + " has received a message");
+
                                 remoteWrapper.notifyDelivery(delivery);
                         } catch (InterruptedException i) {
-                                i.printStackTrace();
+                                logger.error(i);
                         } catch (ShutdownSignalException e) {
-                                e.printStackTrace();
+                                logger.error(e);
                                 try {
                                         if (channel.isOpen()) {
@@ -101 +106 @@
                                                 Thread.sleep(milis);
                                         } catch (InterruptedException e2) {
-                                                e2.printStackTrace();
-                                        }
-                                        e1.printStackTrace();
+                                                logger.error(e2);
+                                        }
+                                        logger.error(e1);
                                 }
                         } catch (ConsumerCancelledException e) {
-                                e.printStackTrace();
+                                logger.error(e);
                         } catch (SerializerException e) {
-                                e.printStackTrace();
+                                logger.error(e);
                         } catch (Exception e) {
-                                e.printStackTrace();
+                                logger.error(e);
                         }
                 }
@@ -129 +134 @@
 
         public void kill() throws IOException {
+                logger.warn("Killing objectmq: " + this.getRef());
                 killed = true;
                 interrupt();
@@ -218 +224 @@
 
                 // Declares and bindings
-                System.out.println("RemoteObject: " + UID + " declaring direct exchange: " + exchange + ", Queue: " + queue);
+                logger.info("RemoteObject: " + UID + " declaring direct exchange: " + exchange + ", Queue: " + queue);
                 channel.exchangeDeclare(exchange, "direct");
                 channel.queueDeclare(queue, durable, false, false, null);
@@ -224 +230 @@
 
                 // Declare the event topic fanout
-                System.out.println("RemoteObject: " + UID + " declaring fanout exchange: " + UID);
+                logger.info("RemoteObject: " + UID + " declaring fanout exchange: " + UID);
                 channel.exchangeDeclare(UID, "fanout");