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

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

Author: pferraro
Date: 2010-08-03 12:44:28 -0400 (Tue, 03 Aug 2010)
New Revision: 107359

Modified:
   projects/cluster/ha-server-cache-ispn/trunk/src/main/java/org/jboss/ha/framework/server/ispn/DistributedState.java
Log:
Inject InfinispanHAPartitionCacheHandler in constructor - instead of setter.  Make cacheHandler final.

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-08-03 16:36:30 UTC (rev 107358)
+++ projects/cluster/ha-server-cache-ispn/trunk/src/main/java/org/jboss/ha/framework/server/ispn/DistributedState.java	2010-08-03 16:44:28 UTC (rev 107359)
@@ -29,6 +29,7 @@
 import java.util.List;
 import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentMap;
 import java.util.concurrent.CopyOnWriteArrayList;
 
 import org.infinispan.Cache;
@@ -67,19 +68,14 @@
 public class DistributedState 
    implements ManagedDistributedState
 {
-   private final ConcurrentHashMap<String, List<DSListener>> keyListeners = new ConcurrentHashMap<String, List<DSListener>>();
+   private final ConcurrentMap<String, List<DSListener>> keyListeners = new ConcurrentHashMap<String, List<DSListener>>();
+   private final InfinispanHAPartitionCacheHandler<Serializable, Serializable> cacheHandler;
 
    private volatile Cache<Serializable, Serializable> cache;
    private volatile boolean replAsync;
-   private volatile InfinispanHAPartitionCacheHandler<Serializable, Serializable> cacheHandler;
 
-   public InfinispanHAPartitionCacheHandler<Serializable, Serializable> getCacheHandler()
+   public DistributedState(InfinispanHAPartitionCacheHandler<Serializable, Serializable> cacheHandler)
    {
-      return cacheHandler;
-   }
-
-   public void setCacheHandler(InfinispanHAPartitionCacheHandler<Serializable, Serializable> cacheHandler)
-   {
       this.cacheHandler = cacheHandler;
    }