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

Timestamp:

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

Author:

stoda

Message:

log4j added

File:

• trunk/src/main/java/omq/server/InvocationThread.java (modified) (5 diffs)

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

@@ -8 +8 @@
 import omq.common.util.Serializer;
 import omq.exception.OmqException;
+
+import org.apache.log4j.Logger;
 
 import com.rabbitmq.client.AMQP.BasicProperties;
@@ -19 +21 @@
  */
 public class InvocationThread extends Thread {
+        private static final Logger logger = Logger.getLogger(InvocationThread.class.getName());
         private RemoteObject obj;
         private BlockingQueue<Delivery> deliveryQueue;
@@ -44 +47 @@
                                 String requestID = request.getId();
 
-                                System.out.println("Invoke method: " + methodName + " CorrID: " + requestID);
+                                logger.debug("Object: " + obj.getRef() + ", method: " + methodName + " corrID: " + requestID);
 
                                 // Invoke the method
@@ -53 +56 @@
                                 } catch (InvocationTargetException e) {
                                         Throwable throwable = e.getTargetException();
+                                        logger.error("Object: " + obj.getRef() + " at method: " + methodName + ", corrID" + requestID, throwable);
                                         error = new OmqException(throwable.getClass().getCanonicalName(), throwable.getMessage());
                                 } catch (NoSuchMethodException e) {
+                                        logger.error("Object: " + obj.getRef() + " cannot find method: " + methodName);
                                         error = new OmqException(e.getClass().getCanonicalName(), e.getMessage());
                                 }
@@ -75 +80 @@
 
                         } catch (InterruptedException i) {
-                                i.printStackTrace();
+                                logger.error(i);
                                 killed = true;
                         } catch (Exception e) {
-                                System.out.println("Error a l'Invocation Thread \nException: " + e);
-                                e.printStackTrace();
+                                logger.error("Object: " + obj.getRef(), e);
                         }