User: slaboure Date: 01/12/29 08:23:11 Added: src/main/org/jboss/ejb/plugins ClusterSyncEntityInstanceCache.java Log: Entity Instance cache for clustered environment with distributed cache synchronization: if a bean is modified on another host, all other distributed cache clean this bean from their cache. Revision Changes Path 1.1 jbossmx/src/main/org/jboss/ejb/plugins/ClusterSyncEntityInstanceCache.java Index: ClusterSyncEntityInstanceCache.java =================================================================== /* * JBoss, the OpenSource J2EE webOS * * Distributable under LGPL license. * See terms of license at gnu.org. */ package org.jboss.ejb.plugins; import java.rmi.RemoteException; import java.rmi.NoSuchObjectException; import org.jboss.ejb.Container; import org.jboss.ejb.EntityContainer; import org.jboss.ejb.CacheKey; import org.jboss.ejb.EnterpriseContext; import org.jboss.ejb.EntityEnterpriseContext; import org.jboss.util.Sync; import org.jboss.ha.framework.interfaces.DistributedState; /** * Cache subclass for entity beans shared accross a cluster with * distributed cache corruption mechanism. * * @author <a href="mailto:[EMAIL PROTECTED]">Sacha Labourey</a> * @version $Revision: 1.1 $ */ public class ClusterSyncEntityInstanceCache extends EntityInstanceCache implements org.jboss.ha.framework.interfaces.DistributedState.DSListener { // Constants ----------------------------------------------------- // Attributes ---------------------------------------------------- protected DistributedState ds = null; protected String DS_CATEGORY = null; // Static -------------------------------------------------------- // Constructors -------------------------------------------------- // Public -------------------------------------------------------- public void create() throws Exception { super.create (); // Get a reference to the DS service // String name = "JBOSS-SYSTEM:service=DistributedState,partitionName=DefaultPartition"; ds = (DistributedState)org.jboss.system.Registry.lookup (name); } public void start() throws Exception { super.start (); String ejbName = this.getContainer ().getBeanMetaData ().getEjbName (); this.DS_CATEGORY = "CMPClusteredInMemoryPersistenceManager-" + ejbName; this.ds.registerDSListener (this.DS_CATEGORY, this); } /* From Service interface*/ public void stop() { super.stop (); this.ds.unregisterDSListener (this.DS_CATEGORY, this); } // DSListener implementation ------------------------------------- /** * Called whenever a key has been removed from a category the called object had * subscribed in. * @param category The category under which a key has been removed * @param key The key that has been removed * @param previousContent The previous content of the key that has been removed */ public void keyHasBeenRemoved (String category, String key, java.io.Serializable previousContent, boolean locallyModified) { if (!locallyModified) this.cacheMiss (key); } /** * Called whenever a key has been added or modified in the category the called object * has subscribed in. * @param category The category of the modified/added entry * @param key The key that has been added or its value modified * @param value The new value of the key */ public void valueHasChanged (String category, String key, java.io.Serializable value, boolean locallyModified) { if (!locallyModified) this.cacheMiss (key); } // Package protected --------------------------------------------- // Protected ----------------------------------------------------- public void cacheMiss (String key) { // a modification has occured on another node, we clean the cache! // try { this.remove (key); } catch (Exception e) { e.printStackTrace (); } } // Private ------------------------------------------------------- // Inner classes ------------------------------------------------- }
_______________________________________________ Jboss-development mailing list [EMAIL PROTECTED] https://lists.sourceforge.net/lists/listinfo/jboss-development