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
