[jboss-cvs] JBossAS SVN: r108110 - projects/cluster/ha-server-cache-ispn/trunk/src/main/java/org/jboss/ha/framework/server/ispn.

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

Author: smarlow at redhat.com
Date: 2010-09-10 15:21:28 -0400 (Fri, 10 Sep 2010)
New Revision: 108110

Modified:
   projects/cluster/ha-server-cache-ispn/trunk/src/main/java/org/jboss/ha/framework/server/ispn/DistributedState.java
Log:
trace logging

Modified: projects/cluster/ha-server-cache-ispn/trunk/src/main/java/org/jboss/ha/framework/server/ispn/DistributedState.java
===================================================================
--- projects/cluster/ha-server-cache-ispn/trunk/src/main/java/org/jboss/ha/framework/server/ispn/DistributedState.java	2010-09-10 18:24:24 UTC (rev 108109)
+++ projects/cluster/ha-server-cache-ispn/trunk/src/main/java/org/jboss/ha/framework/server/ispn/DistributedState.java	2010-09-10 19:21:28 UTC (rev 108110)
@@ -48,6 +48,7 @@
 import org.infinispan.util.SimpleImmutableEntry;
 import org.jboss.ha.core.framework.server.ChannelSource;
 import org.jboss.ha.framework.server.spi.ManagedDistributedState;
+import org.jboss.logging.Logger;
 import org.jgroups.Channel;
 
 /**
@@ -78,6 +79,7 @@
    
    private volatile String cacheName = "DistributedState";
    private volatile Cache<Serializable, Serializable> cache;
+   private static final Logger LOG = Logger.getLogger(DistributedState.class);
 
    public DistributedState(CacheContainerSource cacheHandler)
    {
@@ -226,6 +228,11 @@
    @Override
    public void set(String category, Serializable key, Serializable value, boolean asynchronousCall) throws Exception
    {
+      if (LOG.isTraceEnabled())
+      {
+         LOG.trace("set: category=" + category +", key=" + key +", value=" + value);
+      }
+
       //if (this.replAsync != asynchronousCall)
       //{
       //   if (asynchronousCall)
@@ -275,7 +282,13 @@
    @Override
    public Serializable remove(String category, Serializable key, boolean asynchronousCall) throws Exception
    {
+      if (LOG.isTraceEnabled())
+      {
+         LOG.trace("remove: category=" + category +", key=" + key);
+      }
+      
       Serializable retVal = this.get(category, key);
+
       if (retVal != null)
       {
       //   if (this.replAsync != asynchronousCall)
@@ -304,6 +317,10 @@
          }
 
       }
+      if (LOG.isTraceEnabled())
+      {
+         LOG.trace("remove: category=" + category +", key=" + key +", removed object=" + retVal);
+      }
       return retVal;
    }
 
@@ -504,7 +521,6 @@
    public void nodeRemoved(CacheEntryRemovedEvent event)
    {
       if (event.isPre()) return;
-
       Object key = event.getKey();
 
       if (key instanceof SimpleImmutableEntry)