User: patriot1burke
Date: 02/03/15 14:59:42
Modified: src/main/org/jboss/ejb/plugins Tag: Branch_2_4
BMPPersistenceManager.java
CMPPersistenceManager.java
Log:
fixed bug 529956 BMP cache zombies. bypass catch on findByPrimaryKey with commit
option B or C.
Revision Changes Path
No revision
No revision
1.22.4.4 +8 -3 jboss/src/main/org/jboss/ejb/plugins/BMPPersistenceManager.java
Index: BMPPersistenceManager.java
===================================================================
RCS file:
/cvsroot/jboss/jboss/src/main/org/jboss/ejb/plugins/BMPPersistenceManager.java,v
retrieving revision 1.22.4.3
retrieving revision 1.22.4.4
diff -u -r1.22.4.3 -r1.22.4.4
--- BMPPersistenceManager.java 5 Feb 2002 02:54:32 -0000 1.22.4.3
+++ BMPPersistenceManager.java 15 Mar 2002 22:59:42 -0000 1.22.4.4
@@ -28,6 +28,7 @@
import org.jboss.ejb.EntityCache;
import org.jboss.ejb.EntityPersistenceManager;
import org.jboss.ejb.EntityEnterpriseContext;
+import org.jboss.metadata.ConfigurationMetaData;
/** The persistence manager plugin for BMP beans.
@@ -35,7 +36,7 @@
* @author Rickard �berg ([EMAIL PROTECTED])
* @author <a href="mailto:[EMAIL PROTECTED]";>Marc Fleury</a>
* @author [EMAIL PROTECTED]
- * @version $Revision: 1.22.4.3 $
+ * @version $Revision: 1.22.4.4 $
*/
public class BMPPersistenceManager
implements EntityPersistenceManager
@@ -54,7 +55,7 @@
HashMap createMethods = new HashMap();
HashMap postCreateMethods = new HashMap();
HashMap finderMethods = new HashMap();
-
+ int commitOption;
// Static --------------------------------------------------------
// Constructors --------------------------------------------------
@@ -63,6 +64,8 @@
public void setContainer(Container c)
{
con = (EntityContainer)c;
+ ConfigurationMetaData configuration =
con.getBeanMetaData().getContainerConfiguration();
+ commitOption = configuration.getCommitOption();
}
public void init()
@@ -478,7 +481,9 @@
{
// Check if findByPrimaryKey
// If so we check if the entity is in cache first
- if (finderMethod.getName().equals("findByPrimaryKey"))
+ if (finderMethod.getName().equals("findByPrimaryKey")
+ && commitOption != ConfigurationMetaData.B_COMMIT_OPTION
+ && commitOption != ConfigurationMetaData.C_COMMIT_OPTION)
{
Object key = ctx.getCacheKey();
if (key == null)
1.21.2.3 +432 -426 jboss/src/main/org/jboss/ejb/plugins/CMPPersistenceManager.java
Index: CMPPersistenceManager.java
===================================================================
RCS file:
/cvsroot/jboss/jboss/src/main/org/jboss/ejb/plugins/CMPPersistenceManager.java,v
retrieving revision 1.21.2.2
retrieving revision 1.21.2.3
diff -u -r1.21.2.2 -r1.21.2.3
--- CMPPersistenceManager.java 4 Sep 2001 01:51:07 -0000 1.21.2.2
+++ CMPPersistenceManager.java 15 Mar 2002 22:59:42 -0000 1.21.2.3
@@ -1,9 +1,9 @@
/*
-* JBoss, the OpenSource EJB server
-*
-* Distributable under LGPL license.
-* See terms of license at gnu.org.
-*/
+ * JBoss, the OpenSource EJB server
+ *
+ * Distributable under LGPL license.
+ * See terms of license at gnu.org.
+ */
package org.jboss.ejb.plugins;
import java.lang.reflect.Method;
@@ -36,283 +36,289 @@
import org.jboss.util.FinderResults;
import org.jboss.util.Sync;
+import org.jboss.metadata.ConfigurationMetaData;
/**
-* The CMP Persistence Manager implements the semantics of the CMP
-* EJB 1.1 call back specification.
-*
-* This Manager works with a "EntityPersistenceStore" that takes care of the
-* physical storing of instances (JAWS, JDBC O/R, FILE, Object).
-*
-* @see <related>
-* @author <a href="mailto:[EMAIL PROTECTED]";>Marc Fleury</a>
-* @author <a href="mailto:[EMAIL PROTECTED]";>danch (Dan Christopherson</a>
-* @version $Revision: 1.21.2.2 $
-*/
+ * The CMP Persistence Manager implements the semantics of the CMP
+ * EJB 1.1 call back specification.
+ *
+ * This Manager works with a "EntityPersistenceStore" that takes care of the
+ * physical storing of instances (JAWS, JDBC O/R, FILE, Object).
+ *
+ * @see <related>
+ * @author <a href="mailto:[EMAIL PROTECTED]";>Marc Fleury</a>
+ * @author <a href="mailto:[EMAIL PROTECTED]";>danch (Dan Christopherson</a>
+ * @version $Revision: 1.21.2.3 $
+ */
public class CMPPersistenceManager
-implements EntityPersistenceManager {
- // Constants -----------------------------------------------------
+ implements EntityPersistenceManager {
+ // Constants -----------------------------------------------------
- // Attributes ----------------------------------------------------
- EntityContainer con;
- // Physical persistence implementation
- EntityPersistenceStore store;
+ // Attributes ----------------------------------------------------
+ EntityContainer con;
+ // Physical persistence implementation
+ EntityPersistenceStore store;
+
+ // The EJB Methods, the reason for this class
+ Method ejbLoad;
+ Method ejbStore;
+ Method ejbActivate;
+ Method ejbPassivate;
+ Method ejbRemove;
+
+ HashMap createMethods = new HashMap();
+ HashMap postCreateMethods = new HashMap();
+
+ int commitOption;
+ // Static --------------------------------------------------------
+
+ // Constructors --------------------------------------------------
+
+ // Public --------------------------------------------------------
+ public void setContainer(Container c) {
+ con = (EntityContainer)c;
+ if (store != null) store.setContainer(c);
+ ConfigurationMetaData configuration =
con.getBeanMetaData().getContainerConfiguration();
+ commitOption = configuration.getCommitOption();
+ }
+
+
+ public void setPersistenceStore(EntityPersistenceStore store) {
+ this.store= store;
+
+ //Give it the container
+ if (con!= null) store.setContainer(con);
+ }
+
+ public void init()
+ throws Exception {
+
+ // The common EJB methods
+ ejbLoad = EntityBean.class.getMethod("ejbLoad", new Class[0]);
+ ejbStore = EntityBean.class.getMethod("ejbStore", new Class[0]);
+ ejbActivate = EntityBean.class.getMethod("ejbActivate", new Class[0]);
+ ejbPassivate = EntityBean.class.getMethod("ejbPassivate", new Class[0]);
+ ejbRemove = EntityBean.class.getMethod("ejbRemove", new Class[0]);
- // The EJB Methods, the reason for this class
- Method ejbLoad;
- Method ejbStore;
- Method ejbActivate;
- Method ejbPassivate;
- Method ejbRemove;
-
- HashMap createMethods = new HashMap();
- HashMap postCreateMethods = new HashMap();
-
- // Static --------------------------------------------------------
-
- // Constructors --------------------------------------------------
-
- // Public --------------------------------------------------------
- public void setContainer(Container c) {
- con = (EntityContainer)c;
- if (store != null) store.setContainer(c);
- }
-
-
- public void setPersistenceStore(EntityPersistenceStore store) {
- this.store= store;
-
- //Give it the container
- if (con!= null) store.setContainer(con);
- }
-
- public void init()
- throws Exception {
-
- // The common EJB methods
- ejbLoad = EntityBean.class.getMethod("ejbLoad", new Class[0]);
- ejbStore = EntityBean.class.getMethod("ejbStore", new Class[0]);
- ejbActivate = EntityBean.class.getMethod("ejbActivate", new Class[0]);
- ejbPassivate = EntityBean.class.getMethod("ejbPassivate", new Class[0]);
- ejbRemove = EntityBean.class.getMethod("ejbRemove", new Class[0]);
-
- if (con.getHomeClass() != null)
- {
- Method[] methods = con.getHomeClass().getMethods();
- createMethodCache( methods );
- }
- if (con.getLocalHomeClass() != null)
- {
- Method[] methods = con.getLocalHomeClass().getMethods();
- createMethodCache( methods );
- }
+ if (con.getHomeClass() != null)
+ {
+ Method[] methods = con.getHomeClass().getMethods();
+ createMethodCache( methods );
+ }
+ if (con.getLocalHomeClass() != null)
+ {
+ Method[] methods = con.getLocalHomeClass().getMethods();
+ createMethodCache( methods );
+ }
- store.init();
- }
+ store.init();
+ }
- private void createMethodCache( Method[] methods )
+ private void createMethodCache( Method[] methods )
throws NoSuchMethodException
- {
- // Create cache of create methods
+ {
+ // Create cache of create methods
for (int i = 0; i < methods.length; i++)
{
- if (methods[i].getName().equals("create"))
- {
- createMethods.put(methods[i],
con.getBeanClass().getMethod("ejbCreate", methods[i].getParameterTypes()));
- postCreateMethods.put(methods[i],
con.getBeanClass().getMethod("ejbPostCreate", methods[i].getParameterTypes()));
- }
+ if (methods[i].getName().equals("create"))
+ {
+ createMethods.put(methods[i], con.getBeanClass().getMethod("ejbCreate",
methods[i].getParameterTypes()));
+ postCreateMethods.put(methods[i],
con.getBeanClass().getMethod("ejbPostCreate", methods[i].getParameterTypes()));
+ }
}
- }
+ }
+
+ public void start()
+ throws Exception {
- public void start()
- throws Exception {
+ store.start();
+ }
- store.start();
- }
+ public void stop() {
+ store.stop();
+ }
+
+ public void destroy() {
+ store.destroy();
+ }
+
+ public void createEntity(Method m, Object[] args, EntityEnterpriseContext ctx)
+ throws Exception {
+ // Get methods
+ Method createMethod = (Method)createMethods.get(m);
+ Method postCreateMethod = (Method)postCreateMethods.get(m);
+
+ // Reset all attributes to default value
+ // The EJB 1.1 specification is not entirely clear about this,
+ // the EJB 2.0 spec is, see page 169.
+ // Robustness is more important than raw speed for most server
+ // applications, and not resetting atrribute values result in
+ // *very* weird errors (old states re-appear in different instances and the
+ // developer thinks he's on drugs).
+
+ // first get cmp metadata of this entity
+ Object instance = ctx.getInstance();
+ Class ejbClass = instance.getClass();
+ Field cmpField;
+ Class cmpFieldType;
+ for (Iterator i=
((EntityMetaData)ctx.getContainer().getBeanMetaData()).getCMPFields();
+ 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 if (... cmr collection in ejb2.0...) {
+ //cmpField.set(instance,someNewCollection?);
+
+ } 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 void stop() {
- store.stop();
- }
-
- public void destroy() {
- store.destroy();
- }
-
- public void createEntity(Method m, Object[] args, EntityEnterpriseContext ctx)
- throws Exception {
- // Get methods
- Method createMethod = (Method)createMethods.get(m);
- Method postCreateMethod = (Method)postCreateMethods.get(m);
-
- // Reset all attributes to default value
- // The EJB 1.1 specification is not entirely clear about this,
- // the EJB 2.0 spec is, see page 169.
- // Robustness is more important than raw speed for most server
- // applications, and not resetting atrribute values result in
- // *very* weird errors (old states re-appear in different instances and the
- // developer thinks he's on drugs).
-
- // first get cmp metadata of this entity
- Object instance = ctx.getInstance();
- Class ejbClass = instance.getClass();
- Field cmpField;
- Class cmpFieldType;
- for (Iterator i=
((EntityMetaData)ctx.getContainer().getBeanMetaData()).getCMPFields();
- 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 if (... cmr collection in ejb2.0...) {
- // cmpField.set(instance,someNewCollection?);
-
- } 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);
- }
- }
-
- // Call ejbCreate on the target bean
- try {
- createMethod.invoke(ctx.getInstance(), args);
- } catch (IllegalAccessException e)
- {
- // Throw this as a bean exception...(?)
- throw new EJBException(e);
- } catch (InvocationTargetException ite)
- {
- Throwable e = ite.getTargetException();
- if (e instanceof EJBException)
- {
- // Rethrow exception
- throw (EJBException)e;
- } else if (e instanceof RuntimeException)
- {
- // Wrap runtime exceptions
- throw new EJBException((Exception)e);
- } else if (e instanceof Exception)
- {
+ // Call ejbCreate on the target bean
+ try {
+ createMethod.invoke(ctx.getInstance(), args);
+ } catch (IllegalAccessException e)
+ {
+ // Throw this as a bean exception...(?)
+ throw new EJBException(e);
+ } catch (InvocationTargetException ite)
+ {
+ Throwable e = ite.getTargetException();
+ if (e instanceof EJBException)
+ {
+ // Rethrow exception
+ throw (EJBException)e;
+ } else if (e instanceof RuntimeException)
+ {
+ // Wrap runtime exceptions
+ throw new EJBException((Exception)e);
+ } else if (e instanceof Exception)
+ {
// Remote, Create, or custom app. exception
- throw (Exception)e;
- } else
- {
- throw (Error)e;
- }
+ throw (Exception)e;
+ } else
+ {
+ throw (Error)e;
+ }
}
- // Have the store persist the new instance, the return is the key
- Object id = store.createEntity(m, args, ctx);
+ // Have the store persist the new instance, the return is the key
+ Object id = store.createEntity(m, args, ctx);
- // Set the key on the target context
- ctx.setId(id);
+ // Set the key on the target context
+ ctx.setId(id);
- // Create a new CacheKey
- Object cacheKey = ((EntityCache) con.getInstanceCache()).createCacheKey( id
);
+ // Create a new CacheKey
+ Object cacheKey = ((EntityCache) con.getInstanceCache()).createCacheKey( id );
- // Give it to the context
- ctx.setCacheKey(cacheKey);
+ // Give it to the context
+ ctx.setCacheKey(cacheKey);
- // Create EJBObject
- if (con.getContainerInvoker() != null)
+ // Create EJBObject
+ if (con.getContainerInvoker() != null)
ctx.setEJBObject(con.getContainerInvoker().getEntityEJBObject(cacheKey));
- if (con.getLocalHomeClass() != null)
+ if (con.getLocalHomeClass() != null)
ctx.setEJBLocalObject(con.getLocalContainerInvoker().getEntityEJBLocalObject(cacheKey));
- try
- {
- postCreateMethod.invoke(ctx.getInstance(), args);
- } catch (IllegalAccessException e)
- {
- // Throw this as a bean exception...(?)
- throw new EJBException(e);
- } catch (InvocationTargetException ite)
- {
- Throwable e = ite.getTargetException();
- if (e instanceof EJBException)
- {
- // Rethrow exception
- throw (EJBException)e;
- } else if (e instanceof RuntimeException)
- {
- // Wrap runtime exceptions
- throw new EJBException((Exception)e);
- } else if (e instanceof Exception)
- {
- // Remote, Create, or custom app. exception
- throw (Exception)e;
- } else
- {
- throw (Error)e;
- }
- }
- }
-
- public Object findEntity(Method finderMethod, Object[] args,
EntityEnterpriseContext ctx)
- throws Exception {
- // For now only optimize fBPK
- if (finderMethod.getName().equals("findByPrimaryKey"))
- {
- Object key = ctx.getCacheKey();
- if (key == null)
- {
- key = ((EntityCache)con.getInstanceCache()).createCacheKey(args[0]);
- }
- if (con.getInstanceCache().isActive(key))
- {
- return key; // Object is active -> it exists -> no need to call finder
- }
- }
-
- // The store will find the entity and return the primaryKey
- Object id = store.findEntity(finderMethod, args, ctx);
-
- // We return the cache key
- return ((EntityCache) con.getInstanceCache()).createCacheKey(id);
- }
-
- /** find multiple entities */
- public Collection findEntities(Method finderMethod, Object[] args,
EntityEnterpriseContext ctx)
- throws Exception
- {
- // The store will find the id and return a collection of PrimaryKeys
- FinderResults ids = store.findEntities(finderMethod, args, ctx);
+ try
+ {
+ postCreateMethod.invoke(ctx.getInstance(), args);
+ } catch (IllegalAccessException e)
+ {
+ // Throw this as a bean exception...(?)
+ throw new EJBException(e);
+ } catch (InvocationTargetException ite)
+ {
+ Throwable e = ite.getTargetException();
+ if (e instanceof EJBException)
+ {
+ // Rethrow exception
+ throw (EJBException)e;
+ } else if (e instanceof RuntimeException)
+ {
+ // Wrap runtime exceptions
+ throw new EJBException((Exception)e);
+ } else if (e instanceof Exception)
+ {
+ // Remote, Create, or custom app. exception
+ throw (Exception)e;
+ } else
+ {
+ throw (Error)e;
+ }
+ }
+ }
+
+ public Object findEntity(Method finderMethod, Object[] args,
EntityEnterpriseContext ctx)
+ throws Exception {
+ // For now only optimize fBPK
+ if (finderMethod.getName().equals("findByPrimaryKey")
+ && commitOption != ConfigurationMetaData.B_COMMIT_OPTION
+ && commitOption != ConfigurationMetaData.C_COMMIT_OPTION)
+ {
+ Object key = ctx.getCacheKey();
+ if (key == null)
+ {
+ key = ((EntityCache)con.getInstanceCache()).createCacheKey(args[0]);
+ }
+ if (con.getInstanceCache().isActive(key))
+ {
+ return key; // Object is active -> it exists -> no need to call finder
+ }
+ }
+
+ // The store will find the entity and return the primaryKey
+ Object id = store.findEntity(finderMethod, args, ctx);
+
+ // We return the cache key
+ return ((EntityCache) con.getInstanceCache()).createCacheKey(id);
+ }
+
+ /** find multiple entities */
+ public Collection findEntities(Method finderMethod, Object[] args,
EntityEnterpriseContext ctx)
+ throws Exception
+ {
+ // The store will find the id and return a collection of PrimaryKeys
+ FinderResults ids = store.findEntities(finderMethod, args, ctx);
- store.loadEntities(ids);
+ store.loadEntities(ids);
- // Note: for now we just return the keys - RabbitHole should return the
- // finderResults so that the invoker layer can extend this back
- // giving the client an OO 'cursor'
- return ids.getAllKeys();
- }
+ // Note: for now we just return the keys - RabbitHole should return the
+ // finderResults so that the invoker layer can extend this back
+ // giving the client an OO 'cursor'
+ return ids.getAllKeys();
+ }
- /*
+ /*
* activateEntity(EnterpriseContext ctx)
*
* The method calls the target beans for spec compliant callbacks.
@@ -323,186 +329,186 @@
*
* @see activateEntity on EntityPersistenceStore.java
*/
- public void activateEntity(EntityEnterpriseContext ctx)
- throws RemoteException {
+ public void activateEntity(EntityEnterpriseContext ctx)
+ throws RemoteException {
+
+ // Call bean
+ try
+ {
+ ejbActivate.invoke(ctx.getInstance(), new Object[0]);
+ } catch (IllegalAccessException e)
+ {
+ // Throw this as a bean exception...(?)
+ throw new EJBException(e);
+ } catch (InvocationTargetException ite)
+ {
+ Throwable e = ite.getTargetException();
+ if (e instanceof RemoteException)
+ {
+ // Rethrow exception
+ throw (RemoteException)e;
+ } else if (e instanceof EJBException)
+ {
+ // Rethrow exception
+ throw (EJBException)e;
+ } else if (e instanceof RuntimeException)
+ {
+ // Wrap runtime exceptions
+ throw new EJBException((Exception)e);
+ }
+ }
- // Call bean
- try
- {
- ejbActivate.invoke(ctx.getInstance(), new Object[0]);
- } catch (IllegalAccessException e)
- {
- // Throw this as a bean exception...(?)
- throw new EJBException(e);
- } catch (InvocationTargetException ite)
- {
- Throwable e = ite.getTargetException();
- if (e instanceof RemoteException)
- {
- // Rethrow exception
- throw (RemoteException)e;
- } else if (e instanceof EJBException)
- {
- // Rethrow exception
- throw (EJBException)e;
- } else if (e instanceof RuntimeException)
- {
- // Wrap runtime exceptions
- throw new EJBException((Exception)e);
- }
- }
-
- store.activateEntity(ctx);
- }
-
- public void loadEntity(EntityEnterpriseContext ctx)
- throws RemoteException {
-
- // Have the store load the fields of the instance
- store.loadEntity(ctx);
-
- invokeLoad(ctx);
- }
-
- public void storeEntity(EntityEnterpriseContext ctx)
- throws RemoteException {
- // Logger.debug("Store entity");
- try {
-
- // Prepare the instance for storage
- ejbStore.invoke(ctx.getInstance(), new Object[0]);
- } catch (IllegalAccessException e)
- {
- // Throw this as a bean exception...(?)
- throw new EJBException(e);
- } catch (InvocationTargetException ite)
- {
- Throwable e = ite.getTargetException();
- if (e instanceof RemoteException)
- {
- // Rethrow exception
- throw (RemoteException)e;
- } else if (e instanceof EJBException)
- {
- // Rethrow exception
- throw (EJBException)e;
- } else if (e instanceof RuntimeException)
- {
- // Wrap runtime exceptions
- throw new EJBException((Exception)e);
- }
- }
-
- // Have the store deal with storing the fields of the instance
- store.storeEntity(ctx);
-
- }
-
- public void passivateEntity(EntityEnterpriseContext ctx)
- throws RemoteException {
-
- try {
-
- // Prepare the instance for passivation
- ejbPassivate.invoke(ctx.getInstance(), new Object[0]);
- } catch (IllegalAccessException e)
- {
- // Throw this as a bean exception...(?)
- throw new EJBException(e);
- } catch (InvocationTargetException ite)
- {
- Throwable e = ite.getTargetException();
- if (e instanceof RemoteException)
- {
- // Rethrow exception
- throw (RemoteException)e;
- } else if (e instanceof EJBException)
- {
- // Rethrow exception
- throw (EJBException)e;
- } else if (e instanceof RuntimeException)
- {
- // Wrap runtime exceptions
- throw new EJBException((Exception)e);
- }
- }
-
- store.passivateEntity(ctx);
- }
-
- public void removeEntity(EntityEnterpriseContext ctx)
- throws RemoteException, RemoveException {
-
- try {
-
- // Call ejbRemove
- ejbRemove.invoke(ctx.getInstance(), new Object[0]);
- } catch (IllegalAccessException e)
- {
- // Throw this as a bean exception...(?)
- throw new EJBException(e);
- } catch (InvocationTargetException ite)
- {
- Throwable e = ite.getTargetException();
- if (e instanceof RemoveException)
- {
- // Rethrow exception
- throw (RemoveException)e;
- } else if (e instanceof RemoteException)
- {
- // Rethrow exception
- throw (RemoteException)e;
- } else if (e instanceof EJBException)
- {
- // Rethrow exception
- throw (EJBException)e;
- } else if (e instanceof RuntimeException)
- {
- // Wrap runtime exceptions
- throw new EJBException((Exception)e);
- }
- }
+ store.activateEntity(ctx);
+ }
- store.removeEntity(ctx);
- }
+ public void loadEntity(EntityEnterpriseContext ctx)
+ throws RemoteException {
+
+ // Have the store load the fields of the instance
+ store.loadEntity(ctx);
+
+ invokeLoad(ctx);
+ }
+
+ public void storeEntity(EntityEnterpriseContext ctx)
+ throws RemoteException {
+ // Logger.debug("Store entity");
+ try {
+
+ // Prepare the instance for storage
+ ejbStore.invoke(ctx.getInstance(), new Object[0]);
+ } catch (IllegalAccessException e)
+ {
+ // Throw this as a bean exception...(?)
+ throw new EJBException(e);
+ } catch (InvocationTargetException ite)
+ {
+ Throwable e = ite.getTargetException();
+ if (e instanceof RemoteException)
+ {
+ // Rethrow exception
+ throw (RemoteException)e;
+ } else if (e instanceof EJBException)
+ {
+ // Rethrow exception
+ throw (EJBException)e;
+ } else if (e instanceof RuntimeException)
+ {
+ // Wrap runtime exceptions
+ throw new EJBException((Exception)e);
+ }
+ }
+
+ // Have the store deal with storing the fields of the instance
+ store.storeEntity(ctx);
+
+ }
+
+ public void passivateEntity(EntityEnterpriseContext ctx)
+ throws RemoteException {
+
+ try {
+
+ // Prepare the instance for passivation
+ ejbPassivate.invoke(ctx.getInstance(), new Object[0]);
+ } catch (IllegalAccessException e)
+ {
+ // Throw this as a bean exception...(?)
+ throw new EJBException(e);
+ } catch (InvocationTargetException ite)
+ {
+ Throwable e = ite.getTargetException();
+ if (e instanceof RemoteException)
+ {
+ // Rethrow exception
+ throw (RemoteException)e;
+ } else if (e instanceof EJBException)
+ {
+ // Rethrow exception
+ throw (EJBException)e;
+ } else if (e instanceof RuntimeException)
+ {
+ // Wrap runtime exceptions
+ throw new EJBException((Exception)e);
+ }
+ }
+
+ store.passivateEntity(ctx);
+ }
+
+ public void removeEntity(EntityEnterpriseContext ctx)
+ throws RemoteException, RemoveException {
+
+ try {
+
+ // Call ejbRemove
+ ejbRemove.invoke(ctx.getInstance(), new Object[0]);
+ } catch (IllegalAccessException e)
+ {
+ // Throw this as a bean exception...(?)
+ throw new EJBException(e);
+ } catch (InvocationTargetException ite)
+ {
+ Throwable e = ite.getTargetException();
+ if (e instanceof RemoveException)
+ {
+ // Rethrow exception
+ throw (RemoveException)e;
+ } else if (e instanceof RemoteException)
+ {
+ // Rethrow exception
+ throw (RemoteException)e;
+ } else if (e instanceof EJBException)
+ {
+ // Rethrow exception
+ throw (EJBException)e;
+ } else if (e instanceof RuntimeException)
+ {
+ // Wrap runtime exceptions
+ throw new EJBException((Exception)e);
+ }
+ }
+
+ store.removeEntity(ctx);
+ }
- protected void invokeLoad(EntityEnterpriseContext ctx) throws RemoteException {
- try {
+ protected void invokeLoad(EntityEnterpriseContext ctx) throws RemoteException {
+ try {
+
+ // Call ejbLoad on bean instance, wake up!
+ ejbLoad.invoke(ctx.getInstance(), new Object[0]);
- // Call ejbLoad on bean instance, wake up!
- ejbLoad.invoke(ctx.getInstance(), new Object[0]);
+ } catch (IllegalAccessException e)
+ {
+ // Throw this as a bean exception...(?)
+ throw new EJBException(e);
+ } catch (InvocationTargetException ite)
+ {
+ Throwable e = ite.getTargetException();
+ if (e instanceof RemoteException)
+ {
+ // Rethrow exception
+ throw (RemoteException)e;
+ } else if (e instanceof EJBException)
+ {
+ // Rethrow exception
+ throw (EJBException)e;
+ } else if (e instanceof RuntimeException)
+ {
+ // Wrap runtime exceptions
+ throw new EJBException((Exception)e);
+ }
+ }
+ }
- } catch (IllegalAccessException e)
- {
- // Throw this as a bean exception...(?)
- throw new EJBException(e);
- } catch (InvocationTargetException ite)
- {
- Throwable e = ite.getTargetException();
- if (e instanceof RemoteException)
- {
- // Rethrow exception
- throw (RemoteException)e;
- } else if (e instanceof EJBException)
- {
- // Rethrow exception
- throw (EJBException)e;
- } else if (e instanceof RuntimeException)
- {
- // Wrap runtime exceptions
- throw new EJBException((Exception)e);
- }
- }
- }
-
- // Z implementation ----------------------------------------------
+ // Z implementation ----------------------------------------------
- // Package protected ---------------------------------------------
+ // Package protected ---------------------------------------------
- // Protected -----------------------------------------------------
+ // Protected -----------------------------------------------------
- // Private -------------------------------------------------------
+ // Private -------------------------------------------------------
- // Inner classes -------------------------------------------------
+ // Inner classes -------------------------------------------------
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
