djencks 2004/07/18 18:32:24
Modified: modules/core/src/java/org/openejb/server/ejbd
EJBInvocationStream.java
Log:
Add timer support to session and mdbs. (entities still todo). Adapt to
TransactionContextManager. Adapt to deploying with external plan.
Revision Changes Path
1.2 +19 -19
openejb/modules/core/src/java/org/openejb/server/ejbd/EJBInvocationStream.java
Index: EJBInvocationStream.java
===================================================================
RCS file:
/home/projects/openejb/scm/openejb/modules/core/src/java/org/openejb/server/ejbd/EJBInvocationStream.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- EJBInvocationStream.java 12 Apr 2004 08:31:41 -0000 1.1
+++ EJBInvocationStream.java 18 Jul 2004 22:32:24 -0000 1.2
@@ -49,7 +49,7 @@
import java.lang.reflect.Method;
import org.apache.geronimo.core.service.InvocationKey;
-import org.apache.geronimo.transaction.TransactionContext;
+import org.apache.geronimo.transaction.context.TransactionContext;
import org.openejb.EJBContainer;
import org.openejb.EJBInstanceContext;
import org.openejb.EJBInterfaceType;
@@ -61,13 +61,13 @@
public class EJBInvocationStream extends EJBRequest implements EJBInvocation {
private ObjectInput in;
-
+
private final EJBInvocation invocationState = new EJBInvocationImpl();
private EJBInterfaceType interfaceType;
-
+
private EJBProxyFactory ejbProxyFactory;
private int methodIndex = -1;
-
+
public EJBInvocationStream() {
super();
}
@@ -75,13 +75,13 @@
public EJBInvocationStream(int requestMethod) {
super(requestMethod);
}
-
+
/**
* The EJBProxyFactory must be set before calling getMethodIndex.
*
- * This method won't be needed in the long-run. Eventually,
+ * This method won't be needed in the long-run. Eventually,
* the method index will be part of the protocol.
- *
+ *
* @param EJBProxyFactory ejbProxyFactory
*/
public void setProxyFactory(EJBProxyFactory ejbProxyFactory) {
@@ -143,15 +143,15 @@
public void readExternal(ObjectInput in)
throws IOException, ClassNotFoundException {
clearState();
-
+
this.in = in;
-
+
readRequestMethod(in);
-
+
readContainerId(in);
-
+
readClientIdentity(in);
-
+
switch (super.getRequestMethod()){
case EJB_HOME_CREATE:
case EJB_HOME_FIND:
@@ -161,7 +161,7 @@
case EJB_HOME_REMOVE_BY_PKEY:
interfaceType = EJBInterfaceType.HOME; break;
default:
- interfaceType = EJBInterfaceType.REMOTE;
+ interfaceType = EJBInterfaceType.REMOTE;
}
// finishReadExternal();
}
@@ -182,18 +182,18 @@
}
}
}
-
+
private void finishReadExternal()
throws IOException, ClassNotFoundException {
readPrimaryKey(in);
-
+
readMethod(in);
-
+
readMethodParameters(in);
-
+
loadMethodInstance();
}
-
+
public Object get(InvocationKey arg0) {
return invocationState.get(arg0);
}
