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

Timestamp:

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

Author:

stoda

Message:

log4j added

Location:

trunk/src/main/java/omq/client

Files:

• listener/ResponseListener.java (modified) (5 diffs)
• proxy/CallType.java (deleted)
• proxy/Proxymq.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;

trunk/src/main/java/omq/client/proxy/Proxymq.java

@@ -10 +10 @@
 import java.util.Map;
 import java.util.Properties;
+
+import org.apache.log4j.Logger;
 
 import omq.Remote;
@@ -44 +46 @@
          */
         private static final long serialVersionUID = 1L;
+        private static final Logger logger = Logger.getLogger(Proxymq.class.getName());
         private static Map<String, Object> proxies = new Hashtable<String, Object>();
 
@@ -132 +135 @@
                 // Publish the request
                 if (request.isAsync()) {
-                        System.out.println("Publish async request -> " + request.getId());
+                        logger.debug("Publish async request -> " + request.getId());
                         publishAsyncRequest(request);
                 } else {
-                        System.out.println("Publish sync request -> " + request.getId());
+                        logger.debug("Publish sync request -> " + request.getId());
                         response = publishSyncRequest(request, method.getReturnType());
 
@@ -186 +189 @@
                                 return getResult(corrId, timeout, type);
                         } catch (TimeoutException te) {
-                                System.out.println("Timeout exception catched " + te);
-                                te.printStackTrace();
+                                logger.error(te);
                         }
                         i++;
@@ -292 +294 @@
         public static Object newProxyInstance(ClassLoader loader, Class<?>[] interfaces, Proxymq proxy) {
                 if (proxies.containsKey(proxy.getRef())) {
-                        System.out.println("Proxy trobat");
                         return proxies.get(proxy.getRef());
                 }