| Methods Summary |
|---|
| public void | activateEntity(org.jboss.ejb.EntityEnterpriseContext instance)This method is called when an entity shall be activated.
With the PersistenceManager factorization most EJB calls should not
exists However this calls permits us to introduce optimizations in
the persistence store. Particularly the context has a
"PersistenceContext" that a PersistenceStore can use (JAWS does for
smart updates) and this is as good a callback as any other to set it
up.
|
| public void | create()create the service, do expensive operations etc
BeanMetaData bmd = con.getBeanMetaData();
ClusterConfigMetaData ccmd = bmd.getClusterConfigMetaData ();
String partitionName = ccmd.getPartitionName();
String name = "jboss:service=DistributedState,partitionName="+partitionName;
ds = (DistributedState)org.jboss.system.Registry.lookup (name);
String ejbName = bmd.getEjbName();
this.DS_CATEGORY = "CMPClusteredInMemoryPersistenceManager-" + ejbName;
idField = con.getBeanClass ().getField ("id");
try
{
isModified = con.getBeanClass ().getMethod ("isModified", new Class[0]);
if (!isModified.getReturnType ().equals (Boolean.TYPE))
isModified = null; // Has to have "boolean" as return type!
}
catch (NoSuchMethodException ignored)
{
}
|
| public java.lang.Object | createBeanClassInstance()Returns a new instance of the bean class or a subclass of the bean class.
return con.getBeanClass ().newInstance ();
|
| public java.lang.Object | createEntity(java.lang.reflect.Method m, java.lang.Object[] args, org.jboss.ejb.EntityEnterpriseContext ctx)This method is called whenever an entity is to be created.
The persistence manager is responsible for handling the results properly
wrt the persistent store.
try
{
Object id = idField.get (ctx.getInstance ());
// Check exist
if (this.ds.get (DS_CATEGORY, id.toString ()) != null)
throw new javax.ejb.DuplicateKeyException ("Already exists:"+id);
// Store to file
storeEntity (id, ctx.getInstance ());
return id;
}
catch (IllegalAccessException e)
{
throw new javax.ejb.CreateException ("Could not create entity:"+e);
}
|
| public void | destroy()destroy the service, tear down
|
| public java.util.Collection | findEntities(java.lang.reflect.Method finderMethod, java.lang.Object[] args, org.jboss.ejb.EntityEnterpriseContext instance, org.jboss.ejb.GenericEntityObjectFactory factory)This method is called when collections of entities are to be found. The
persistence manager must find out whether the wanted instances are
available in the persistence store, and if so it must return a
collection of primaryKeys.
Collection results = Collections.EMPTY_LIST;
if (finderMethod.getName ().equals ("findAll"))
{
Collection tmpColl = this.ds.getAllKeys (DS_CATEGORY);
if (tmpColl != null)
results = GenericEntityObjectFactory.UTIL.getEntityCollection(factory, tmpColl);
}
return results;
|
| public java.lang.Object | findEntity(java.lang.reflect.Method finderMethod, java.lang.Object[] args, org.jboss.ejb.EntityEnterpriseContext instance, org.jboss.ejb.GenericEntityObjectFactory factory)This method is called when single entities are to be found. The
persistence manager must find out whether the wanted instance is
available in the persistence store, if so it returns the primary key of
the object.
if (finderMethod.getName ().equals ("findByPrimaryKey"))
{
if (this.ds.get (DS_CATEGORY, args[0].toString ()) == null)
throw new javax.ejb.FinderException (args[0]+" does not exist");
return factory.getEntityEJBObject(args[0]);
}
else
return null;
|
| public void | initEntity(org.jboss.ejb.EntityEnterpriseContext ctx)Initializes the instance context.
This method is called before createEntity, and should
reset the value of all cmpFields to 0 or null.
// first get cmp metadata of this entity
Object instance = ctx.getInstance ();
Class ejbClass = instance.getClass ();
Field cmpField;
Class cmpFieldType;
EntityMetaData metaData = (EntityMetaData)con.getBeanMetaData ();
java.util.Iterator i= metaData.getCMPFields ();
while(i.hasNext ())
{
try
{
// get the field declaration
try
{
cmpField = ejbClass.getField ((String)i.next ());
cmpFieldType = cmpField.getType ();
// find the type of the field and reset it
// to the default value
if (cmpFieldType.equals (boolean.class))
{
cmpField.setBoolean (instance,false);
}
else if (cmpFieldType.equals (byte.class))
{
cmpField.setByte (instance,(byte)0);
}
else if (cmpFieldType.equals (int.class))
{
cmpField.setInt (instance,0);
}
else if (cmpFieldType.equals (long.class))
{
cmpField.setLong (instance,0L);
}
else if (cmpFieldType.equals (short.class))
{
cmpField.setShort (instance,(short)0);
}
else if (cmpFieldType.equals (char.class))
{
cmpField.setChar (instance,'\u0000");
}
else if (cmpFieldType.equals (double.class))
{
cmpField.setDouble (instance,0d);
}
else if (cmpFieldType.equals (float.class))
{
cmpField.setFloat (instance,0f);
}
else
{
cmpField.set (instance,null);
}
}
catch (NoSuchFieldException e)
{
// will be here with dependant value object's private attributes
// should not be a problem
}
}
catch (Exception e)
{
throw new EJBException (e);
}
}
|
| public boolean | isModified(org.jboss.ejb.EntityEnterpriseContext ctx)
return isStoreRequired(ctx);
|
| public boolean | isStoreRequired(org.jboss.ejb.EntityEnterpriseContext ctx)This method is used to determine if an entity should be stored.
if(isModified == null)
{
return true;
}
Object[] args =
{};
Boolean modified = (Boolean) isModified.invoke (ctx.getInstance (), args);
return modified.booleanValue ();
|
| public void | loadEntity(org.jboss.ejb.EntityEnterpriseContext ctx)This method is called whenever an entity shall be load from the
underlying storage. The persistence manager must load the state from
the underlying storage and then call ejbLoad on the supplied instance.
try
{
// Read fields
byte[] content = (byte[])this.ds.get (this.DS_CATEGORY, ctx.getId ().toString ());
if (content == null)
throw new javax.ejb.EJBException ("No entry exists (any more?) with this id: " + ctx.getId ());
java.io.ObjectInputStream in = new org.jboss.ejb.plugins.CMPClusteredInMemoryPersistenceManager.CMPObjectInputStream (
new java.io.ByteArrayInputStream (content));
Object obj = ctx.getInstance ();
Field[] f = obj.getClass ().getFields ();
for (int i = 0; i < f.length; i++)
{
f[i].set (obj, in.readObject ());
}
in.close ();
}
catch (javax.ejb.EJBException e)
{
throw e;
}
catch (Exception e)
{
throw new EJBException ("Load failed", e);
}
|
| public void | passivateEntity(org.jboss.ejb.EntityEnterpriseContext instance)This method is called when an entity shall be passivate. The persistence
manager must call the ejbPassivate method on the instance.
See the activate discussion for the reason for exposing EJB callback
calls to the store.
// This plugin doesn't do anything specific
|
| public java.lang.Object | postCreateEntity(java.lang.reflect.Method m, java.lang.Object[] args, org.jboss.ejb.EntityEnterpriseContext ctx)This method is called after the ejbCreate.
The persistence manager is responsible for handling the results properly
wrt the persistent store.
return null;
|
| public void | removeEntity(org.jboss.ejb.EntityEnterpriseContext ctx)This method is called when an entity shall be removed from the
underlying storage. The persistence manager must call ejbRemove on the
instance and then remove its state from the underlying storage.
try
{
if (this.ds.remove (this.DS_CATEGORY, ctx.getId ().toString (), false) == null)
throw new javax.ejb.RemoveException ("Could not remove bean:" +
ctx.getId ());
}
catch (Exception e)
{
throw new javax.ejb.RemoveException (e.toString ());
}
|
| public void | setContainer(org.jboss.ejb.Container con)This callback is set by the container so that the plugin may access it
this.con = (org.jboss.ejb.EntityContainer)con;
|
| public void | start()start the service, create is already called
|
| public void | stop()stop the service
|
| public void | storeEntity(org.jboss.ejb.EntityEnterpriseContext ctx)This method is called whenever an entity shall be stored to the
underlying storage. The persistence manager must call ejbStore on the
supplied instance and then store the state to the underlying storage.
B
try
{
storeEntity (ctx.getId (), ctx.getInstance ());
}
catch (Exception e)
{
throw new java.rmi.RemoteException (e.toString ());
}
|
| protected void | storeEntity(java.lang.Object id, java.lang.Object obj)
try
{
// Store fields
java.io.ByteArrayOutputStream baos = new java.io.ByteArrayOutputStream ();
java.io.ObjectOutputStream out = new org.jboss.ejb.plugins.CMPClusteredInMemoryPersistenceManager.CMPObjectOutputStream (baos);
Field[] f = obj.getClass ().getFields ();
for (int i = 0; i < f.length; i++)
{
out.writeObject (f[i].get (obj));
}
out.close ();
this.ds.set (this.DS_CATEGORY, id.toString (), baos.toByteArray (), false);
} catch (Exception e)
{
throw new EJBException ("Store failed", e);
}
|
