[jboss-cvs] JBoss Messaging SVN: r3729 - in trunk/src/main/org/jboss: messaging/core/remoting and 2 other directories.

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

Author: jmesnil
Date: 2008-02-18 04:46:19 -0500 (Mon, 18 Feb 2008)
New Revision: 3729

Modified:
   trunk/src/main/org/jboss/jms/server/endpoint/ServerSessionEndpoint.java
   trunk/src/main/org/jboss/messaging/core/remoting/PacketSender.java
   trunk/src/main/org/jboss/messaging/core/remoting/impl/invm/INVMSession.java
   trunk/src/main/org/jboss/messaging/core/remoting/impl/mina/MinaHandler.java
Log:
* added method PacketSender.getRemoteAddress():String 

Modified: trunk/src/main/org/jboss/jms/server/endpoint/ServerSessionEndpoint.java
===================================================================
--- trunk/src/main/org/jboss/jms/server/endpoint/ServerSessionEndpoint.java	2008-02-18 09:14:00 UTC (rev 3728)
+++ trunk/src/main/org/jboss/jms/server/endpoint/ServerSessionEndpoint.java	2008-02-18 09:46:19 UTC (rev 3729)
@@ -200,6 +200,9 @@
       this.sender = sender;
 
       this.resourceManager = resourceManager;
+      
+      if (log.isTraceEnabled())
+         log.trace("created server session endpoint for " + sender.getRemoteAddress());
    }
 
    // Public

Modified: trunk/src/main/org/jboss/messaging/core/remoting/PacketSender.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/PacketSender.java	2008-02-18 09:14:00 UTC (rev 3728)
+++ trunk/src/main/org/jboss/messaging/core/remoting/PacketSender.java	2008-02-18 09:46:19 UTC (rev 3729)
@@ -19,4 +19,6 @@
    void send(Packet packet) throws Exception;
 
    String getSessionID();
+   
+   String getRemoteAddress();
 }

Modified: trunk/src/main/org/jboss/messaging/core/remoting/impl/invm/INVMSession.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/impl/invm/INVMSession.java	2008-02-18 09:14:00 UTC (rev 3728)
+++ trunk/src/main/org/jboss/messaging/core/remoting/impl/invm/INVMSession.java	2008-02-18 09:46:19 UTC (rev 3729)
@@ -86,6 +86,11 @@
                {
                   return getID();
                }
+               
+               public String getRemoteAddress()
+               {
+                  return "invm";
+               }
             });
    }
 
@@ -123,6 +128,11 @@
                {
                   return getID();
                }
+               
+               public String getRemoteAddress()
+               {
+                  return "invm";
+               }
             });
 
       if (responses[0] == null)

Modified: trunk/src/main/org/jboss/messaging/core/remoting/impl/mina/MinaHandler.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/impl/mina/MinaHandler.java	2008-02-18 09:14:00 UTC (rev 3728)
+++ trunk/src/main/org/jboss/messaging/core/remoting/impl/mina/MinaHandler.java	2008-02-18 09:46:19 UTC (rev 3729)
@@ -110,6 +110,11 @@
          {
             return Long.toString(session.getId());
          }
+         
+         public String getRemoteAddress()
+         {
+            return session.getRemoteAddress().toString();
+         }
       };
 
       if (log.isTraceEnabled())