[jboss-remoting-commits] JBoss Remoting SVN: r4090 - remoting2/branches/2.x/src/main/org/jboss/remoting/detection/multicast.

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

Author: ron.sigal at jboss.com
Date: 2008-04-29 02:34:56 -0400 (Tue, 29 Apr 2008)
New Revision: 4090

Modified:
   remoting2/branches/2.x/src/main/org/jboss/remoting/detection/multicast/MulticastDetector.java
Log:
JBREM-930: Added "this" to log statements.

Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/detection/multicast/MulticastDetector.java
===================================================================
--- remoting2/branches/2.x/src/main/org/jboss/remoting/detection/multicast/MulticastDetector.java	2008-04-29 06:06:13 UTC (rev 4089)
+++ remoting2/branches/2.x/src/main/org/jboss/remoting/detection/multicast/MulticastDetector.java	2008-04-29 06:34:56 UTC (rev 4090)
@@ -202,7 +202,7 @@
          catch (Exception e)
          {
             {
-               log.warn("Error stopping multicast detector.  " + e.getMessage());
+               log.warn(this + " Error stopping multicast detector.  " + e.getMessage());
             }         }
          listener = null;
       }
@@ -215,7 +215,7 @@
          }
          catch (IOException e)
          {
-            log.warn("Error stopping multicast detector.  " + e.getMessage());
+            log.warn(this + " Error stopping multicast detector.  " + e.getMessage());
          }
          socket = null;
       }
@@ -234,7 +234,7 @@
          {
             if(log.isTraceEnabled())
             {
-               log.trace("sending heartbeat: " + msg);
+               log.trace(this + " sending heartbeat: " + msg);
             }
             ByteArrayOutputStream byteOut = new ByteArrayOutputStream();
             ObjectOutputStream objectOut = new ObjectOutputStream(byteOut);
@@ -248,7 +248,7 @@
          catch(Throwable ex)
          {
             // its failed
-            log.debug("heartbeat failed", ex);
+            log.debug(this + " heartbeat failed", ex);
          }
       }
    }
@@ -283,7 +283,7 @@
          catch(Throwable ex)
          {
             // its failed
-            log.debug("forced heartbeat failed", ex);
+            log.debug(this + " forced heartbeat failed", ex);
          }
       }
    }
@@ -306,7 +306,7 @@
                Detection msg = (Detection)obj;
                if(log.isTraceEnabled())
                {
-                  log.trace("received detection: " + msg);
+                  log.trace(this + " received detection: " + msg);
                }
 
                // let the subclass do the hard work off handling detection
@@ -327,7 +327,7 @@
             }
             if(socket != null)
             {
-               log.debug("Error receiving detection", e);
+               log.debug(this + " Error receiving detection", e);
             }
          }
       }