Changeset 49 for trunk/src/main/java/omq/common/event/EventDispatcher.java

Timestamp:

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

Author:

stoda

Message:

log4j added

File:

• trunk/src/main/java/omq/common/event/EventDispatcher.java (modified) (7 diffs)

trunk/src/main/java/omq/common/event/EventDispatcher.java

@@ -9 +9 @@
 import omq.common.util.ParameterQueue;
 import omq.common.util.Serializer;
+
+import org.apache.log4j.Logger;
 
 import com.rabbitmq.client.Channel;
@@ -26 +28 @@
 @SuppressWarnings("rawtypes")
 public class EventDispatcher extends Thread {
+        private static final Logger logger = Logger.getLogger(EventDispatcher.class.getName());
         private static EventDispatcher dispatcher;
 
@@ -67 +70 @@
 
         public static void stopEventDispatcher() throws Exception {
+                logger.warn("Stopping EventDispatcher");
                 dispatcher.setListeners(null);
                 dispatcher.killed = true;
@@ -102 +106 @@
                                 event = Serializer.deserializeEvent(delivery.getBody());
 
-                                System.out.println("Event received -> Topic: " + event.getTopic() + "CorrId: " + event.getCorrId());
+                                logger.info("Event received -> Topic: " + event.getTopic() + "CorrId: " + event.getCorrId());
                                 // Log.saveLog("Client-Deserialize", delivery.getBody());
 
@@ -112 +116 @@
                                 dispatch(event.getTopic(), event);
                         } catch (InterruptedException i) {
-                                System.out.println("InterruptedException e: " + i);
-                                i.printStackTrace();
+                                logger.error(i);
                         } catch (ShutdownSignalException e) {
-                                System.out.println("ShutdownSignalException e: " + e);
-                                e.printStackTrace();
+                                logger.error(e);
                                 try {
                                         if (channel.isOpen()) {
@@ -127 +129 @@
                                                 Thread.sleep(milis);
                                         } catch (InterruptedException e2) {
-                                                e2.printStackTrace();
+                                                logger.error(e2);
                                         }
-                                        e1.printStackTrace();
+                                        logger.error(e1);
                                 }
                         } catch (ConsumerCancelledException e) {
-                                System.out.println("ConsumerCancelledException e: " + e);
-                                e.printStackTrace();
+                                logger.error(e);
                         } catch (Exception e) {
-                                System.out.println("Exception e: " + e);
-                                e.printStackTrace();
+                                logger.error(e);
                         }
                 }
@@ -160 +160 @@
                         String reference = e.getTopic();
 
-                        System.out.println("EventDispatcher declaring fanout -> " + reference + " Binding with: " + queueName);
+                        logger.info("Declaring fanout -> " + reference + " Binding with: " + queueName);
 
                         channel.exchangeDeclare(reference, "fanout");