[jboss-cvs] JBoss Messaging SVN: r3394 - branches/Branch_JBMESSAGING-544/src/main/org/jboss/messaging/core/remoting/internal.

[jboss-cvs-commits at lists.jboss.org]

Author: jmesnil
Date: 2007-12-03 05:13:09 -0500 (Mon, 03 Dec 2007)
New Revision: 3394

Modified:
   branches/Branch_JBMESSAGING-544/src/main/org/jboss/messaging/core/remoting/internal/ClientHandler.java
Log:
http://jira.jboss.org/jira/browse/JBMESSAGING-544 Replace client-server transport with NIO based transport
* added trace and error logging

Modified: branches/Branch_JBMESSAGING-544/src/main/org/jboss/messaging/core/remoting/internal/ClientHandler.java
===================================================================
--- branches/Branch_JBMESSAGING-544/src/main/org/jboss/messaging/core/remoting/internal/ClientHandler.java	2007-12-03 07:02:48 UTC (rev 3393)
+++ branches/Branch_JBMESSAGING-544/src/main/org/jboss/messaging/core/remoting/internal/ClientHandler.java	2007-12-03 10:13:09 UTC (rev 3394)
@@ -9,6 +9,7 @@
 import org.apache.mina.common.IoHandlerAdapter;
 import org.apache.mina.common.IoSession;
 import org.apache.mina.filter.reqres.Response;
+import org.jboss.logging.Logger;
 import org.jboss.messaging.core.remoting.PacketDispatcher;
 import org.jboss.messaging.core.remoting.PacketHandler;
 import org.jboss.messaging.core.remoting.PacketSender;
@@ -23,6 +24,8 @@
 {
    // Constants -----------------------------------------------------
 
+   private static final Logger log = Logger.getLogger(ClientHandler.class);
+
    // Attributes ----------------------------------------------------
 
    // Static --------------------------------------------------------
@@ -40,12 +43,17 @@
       if (message instanceof AbstractPacket)
       {
          AbstractPacket packet = (AbstractPacket) message;
-         System.err.println("ClientHandler.messageReceived() packet: " + packet);
+ 
+         if (log.isTraceEnabled())
+            log.trace("received packet " + packet);
+         
          String targetID = packet.getTargetID();
          PacketHandler handler = PacketDispatcher.client.getHandler(targetID);
          if (handler != null)
          {
-            System.err.println("ClientHandler.messageReceived() handler: " + handler);
+            if (log.isTraceEnabled())
+               log.trace(handler + " handles " + packet);
+            
             handler.handle(packet, new PacketSender() {
                public void send(AbstractPacket p)
                {
@@ -55,9 +63,7 @@
             });
          } else
          {
-            System.err
-                  .println("ClientHandler.messageReceived() unhandled packet: "
-                        + packet);
+            log.error("unhandled packet " + packet);
          }
       } else if (message instanceof Response)
       {
@@ -65,7 +71,7 @@
          // do nothing
       } else
       {
-         System.err.println("unhandled message: " + message);
+         log.error("unhandled remote message " + message);
       }
    }