Changeset 49 for trunk/src/main/java/omq/client/listener

Timestamp:

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

Author:

stoda

Message:

log4j added

File:

• trunk/src/main/java/omq/client/listener/ResponseListener.java (modified) (5 diffs)

trunk/src/main/java/omq/client/listener/ResponseListener.java

@@ -6 +6 @@
 import java.util.Map;
 import java.util.Properties;
+
+import org.apache.log4j.Logger;
 
 import omq.client.proxy.Proxymq;
@@ -26 +28 @@
  */
 public class ResponseListener extends Thread {
+        private static final Logger logger = Logger.getLogger(ResponseListener.class.getName());
         private static ResponseListener rListener;
 
@@ -78 +81 @@
                                 }
                         } catch (InterruptedException i) {
-                                i.printStackTrace();
+                                logger.error(i.toString(), i);
                         } catch (ShutdownSignalException e) {
-                                e.printStackTrace();
+                                logger.error(e.toString(), e);
                                 try {
                                         if (channel.isOpen()) {
@@ -92 +95 @@
                                                 Thread.sleep(milis);
                                         } catch (InterruptedException e2) {
-                                                e2.printStackTrace();
+                                                logger.error(e2.toString(), e2);
                                         }
                                 }
                         } catch (ConsumerCancelledException e) {
-                                e.printStackTrace();
+                                logger.error(e.toString(), e);
                         } catch (Exception e) {
-                                e.printStackTrace();
+                                logger.error(e.toString(), e);
                         }
                 }
@@ -201 +204 @@
          */
         public void kill() throws IOException {
+                logger.warn("Killing ResponseListener");
                 interrupt();
                 killed = true;