[prev in list] [next in list] [prev in thread] [next in thread] 

List:       jboss-cvs-commits
Subject:    [jboss-cvs] jboss-ejb3/src/main/org/jboss/ejb3/stateless StatelessContainer.java StatelessRemoteProx
From:       Bill Burke <patriot1burke () users ! sourceforge ! net>
Date:       2004-08-31 21:29:57
Message-ID: E1C2GCT-0005IR-8q () sc8-pr-cvs1 ! sourceforge ! net
[Download RAW message or body]

  User: patriot1burke
  Date: 04/08/31 14:29:57

  Modified:    src/main/org/jboss/ejb3/stateless StatelessContainer.java
                        StatelessRemoteProxy.java
                        StatelessRemoteProxyFactory.java
  Log:
  remoting for EJB3 and test for it
  
  Revision  Changes    Path
  1.4       +2 -1      \
jboss-ejb3/src/main/org/jboss/ejb3/stateless/StatelessContainer.java  
  Index: StatelessContainer.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-ejb3/src/main/org/jboss/ejb3/stateless/StatelessContainer.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -r1.3 -r1.4
  --- StatelessContainer.java	27 Aug 2004 20:40:10 -0000	1.3
  +++ StatelessContainer.java	31 Aug 2004 21:29:56 -0000	1.4
  @@ -30,7 +30,7 @@
    * Comment
    *
    * @author <a href="mailto:bill@jboss.org">Bill Burke</a>
  - * @version $Revision: 1.3 $
  + * @version $Revision: 1.4 $
    *
    **/
   public class StatelessContainer extends SessionContainer implements \
StatelessContainerMBean, TimedObjectInvoker  @@ -147,6 +147,7 @@
            }
            newSi = new EJBContainerInvocation(si.getMethodHash(), method, \
si.getArguments(), serverInterceptors);  newSi.setContainer(this);
  +         newSi.setMetaData(si.getMetaData());
   
            Object rtn = newSi.invokeNext();
            InvocationResponse response = new InvocationResponse(rtn);
  
  
  
  1.2       +3 -1      \
jboss-ejb3/src/main/org/jboss/ejb3/stateless/StatelessRemoteProxy.java  
  Index: StatelessRemoteProxy.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-ejb3/src/main/org/jboss/ejb3/stateless/StatelessRemoteProxy.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -r1.1 -r1.2
  --- StatelessRemoteProxy.java	27 Aug 2004 20:40:10 -0000	1.1
  +++ StatelessRemoteProxy.java	31 Aug 2004 21:29:56 -0000	1.2
  @@ -22,12 +22,13 @@
   import org.jboss.remoting.InvokerLocator;
   
   import java.lang.reflect.Method;
  +import java.util.Iterator;
   
   /**
    * Comment
    *
    * @author <a href="mailto:bill@jboss.org">Bill Burke</a>
  - * @version $Revision: 1.1 $
  + * @version $Revision: 1.2 $
    *
    **/
   public class StatelessRemoteProxy extends org.jboss.ejb3.remoting.BaseRemoteProxy
  @@ -37,13 +38,14 @@
         super(containerId, interceptors, uri);
      }
   
  +   protected StatelessRemoteProxy() {}
  +
   
      public Object invoke(Object proxy, Method method, Object[] args)
              throws Throwable
      {
         long hash = MethodHashing.calculateHash(method);
         EJBRemoteInvocation sri = new EJBRemoteInvocation(containerId, method, hash, \
                args, interceptors, metadata);
  -      sri.getMetaData().addMetaData(InvokeRemoteInterceptor.REMOTING, \
InvokeRemoteInterceptor.SUBSYSTEM, "EJB3", PayloadKey.AS_IS);  return \
sri.invokeNext();  }
   }
  
  
  
  1.2       +4 -4      \
jboss-ejb3/src/main/org/jboss/ejb3/stateless/StatelessRemoteProxyFactory.java  
  Index: StatelessRemoteProxyFactory.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-ejb3/src/main/org/jboss/ejb3/stateless/StatelessRemoteProxyFactory.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -r1.1 -r1.2
  --- StatelessRemoteProxyFactory.java	27 Aug 2004 20:40:10 -0000	1.1
  +++ StatelessRemoteProxyFactory.java	31 Aug 2004 21:29:56 -0000	1.2
  @@ -37,9 +37,9 @@
    * Comment
    *
    * @author <a href="mailto:bill@jboss.org">Bill Burke</a>
  - * @version $Revision: 1.1 $
  + * @version $Revision: 1.2 $
    */
  -public class StatelessRemoteProxyFactory extends BaseStatefulProxyFactory \
implements RemoteProxyFactory  +public class StatelessRemoteProxyFactory extends \
BaseStatelesslProxyFactory implements RemoteProxyFactory  {
      private RemoteBinding binding;
      private InvokerLocator locator;
  @@ -61,15 +61,15 @@
   
      public void start() throws Exception
      {
  -      super.start();
         locator = new InvokerLocator(binding.clientBindUrl());
  +      super.start();
      }
   
      public Object createProxy()
      {
         try
         {
  -         Integer containerId = new \
Integer(container.getObjectName().toString().hashCode());  +         Integer \
                containerId = new Integer(container.getObjectName().hashCode());
            AdviceStack stack = \
                AspectManager.instance().getAdviceStack(binding.interceptorStack());
            Object[] args = {new StatelessRemoteProxy(containerId, \
stack.createInterceptors(), locator)};  return proxyConstructor.newInstance(args);
  
  
  


-------------------------------------------------------
This SF.Net email is sponsored by BEA Weblogic Workshop
FREE Java Enterprise J2EE developer tools!
Get your free copy of BEA WebLogic Workshop 8.1 today.
http://ads.osdn.com/?ad_id=5047&alloc_id=10808&op=click
_______________________________________________
jboss-cvs-commits mailing list
jboss-cvs-commits@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/jboss-cvs-commits


[prev in list] [next in list] [prev in thread] [next in thread]