Changeset 49 for trunk/src/main/java/omq/client/proxy/Proxymq.java

Timestamp:

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

Author:

stoda

Message:

log4j added

File:

• trunk/src/main/java/omq/client/proxy/Proxymq.java (modified) (5 diffs)

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());
                 }