FileDocCategorySizeDatePackage
BeanCorbaServant.javaAPI DocJBoss 4.2.19273Fri Jul 13 20:53:50 BST 2007org.jboss.ejb3.iiop

BeanCorbaServant

public class BeanCorbaServant extends Servant implements InvokeHandler
Comment
author
Carlo de Wolf
version
$Revision: 60233 $

Fields Summary
private static final org.jboss.logging.Logger
log
private final IORFactory
factory
private final Current
poaCurrent
private final org.jboss.ejb3.Container
container
private final org.omg.CORBA.InterfaceDef
interfaceDef
private final String[]
repositoryIds
private org.jboss.iiop.csiv2.SASCurrent
sasCurrent
private HashMap
methodMap
Constructors Summary
protected BeanCorbaServant(IORFactory factory, Current poaCurrent, org.jboss.ejb3.Container container, org.omg.CORBA.InterfaceDef interfaceDef, org.jboss.iiop.rmi.InterfaceAnalysis interfaceAnalysis)

   
             
   
      assert factory != null;
      assert poaCurrent != null;
      assert container != null;
      assert container instanceof SessionContainer; // see invoke
      assert interfaceDef != null;
      assert interfaceAnalysis != null;
      
      this.factory = factory;
      this.poaCurrent = poaCurrent;
      this.container = container;
      this.interfaceDef = interfaceDef;
      this.repositoryIds = interfaceAnalysis.getAllTypeIds();
      
      try
      {
         this.sasCurrent = (SASCurrent) CorbaORB.getInstance().resolve_initial_references("SASCurrent");
      }
      catch (InvalidName e)
      {
         log.warn("Can't find SASCurrent");
         this.sasCurrent = null;
      }
      
      this.methodMap = new HashMap<String, SkeletonStrategy>();
      AttributeAnalysis[] attrs = interfaceAnalysis.getAttributes();
      for (int i = 0; i < attrs.length; i++) {
         OperationAnalysis op = attrs[i].getAccessorAnalysis();

         log.debug("    " + op.getJavaName() + ": " + op.getIDLName());
         methodMap.put(op.getIDLName(),
                           new SkeletonStrategy(op.getMethod()));
         op = attrs[i].getMutatorAnalysis();
         if (op != null) {
            log.debug("    " + op.getJavaName() + ": " + op.getIDLName());
            methodMap.put(op.getIDLName(),
                              new SkeletonStrategy(op.getMethod()));
         }
      }

      OperationAnalysis[] ops = interfaceAnalysis.getOperations();
      for (int i = 0; i < ops.length; i++) {
         log.debug("    " + ops[i].getJavaName() + ": " + ops[i].getIDLName());
         methodMap.put(ops[i].getIDLName(),
                           new SkeletonStrategy(ops[i].getMethod()));
      }
   
Methods Summary
public java.lang.String[]_all_interfaces(org.omg.PortableServer.POA poa, byte[] objectId)

      return (String[]) repositoryIds.clone();
   
public org.omg.CORBA.Object_get_interface_def()
Returns an IR object describing the bean's remote interface.

      if (interfaceDef != null)
         return interfaceDef;
      else
         return super._get_interface_def();
   
public org.omg.CORBA.portable.OutputStream_invoke(java.lang.String opName, org.omg.CORBA.portable.InputStream in, org.omg.CORBA.portable.ResponseHandler handler)

      log.trace("invoke: " + opName);
      
      SkeletonStrategy op = (SkeletonStrategy) methodMap.get(opName);
      if (op == null)
      {
         log.debug("Unable to find opname '" + opName + "' valid operations:" + methodMap.keySet());
         throw new BAD_OPERATION(opName);
      }

      org.omg.CORBA_2_3.portable.OutputStream out;
      try
      {
         Object id = ReferenceData.extractObjectId(poaCurrent.get_object_id());
         log.trace("id = " + id);
         
         Transaction tx = TxServerInterceptor.getCurrentTransaction();
         log.trace("tx = " + tx);
         
         if(sasCurrent != null)
         {
            byte username[] = sasCurrent.get_incoming_username();
            byte credentials[] = sasCurrent.get_incoming_password();
            byte principalName[] = sasCurrent.get_incoming_principal_name();
            
            if(username != null && username.length > 0)
            {
               String name = new String(username, "UTF-8");
               int domainIndex = name.lastIndexOf("@");
               if(domainIndex > 0)
                  name = name.substring(0, domainIndex);
               log.debug("username = " + name);
               Principal principal = new SimplePrincipal(name);
               SecurityAssociation.setPrincipal(principal);
            }
            
            if(credentials != null && credentials.length > 0)
            {
               SecurityAssociation.setCredential(new String(credentials, "UTF-8").toCharArray());
            }
            
            if(principalName != null && principalName.length > 0)
               log.warn("principalName = " + new String(principalName, "UTF-8")); // FIXME: implement principalName support
         }
         
         Object args[] = op.readParams((org.omg.CORBA_2_3.portable.InputStream) in);
         
         Object retVal = invoke(tx, id, op.getMethod(), args);
         
         out = (org.omg.CORBA_2_3.portable.OutputStream) handler.createReply();
         if(op.isNonVoid())
            op.writeRetval(out, retVal);
      }
      catch(Throwable t)
      {
         // TODO: check log level before stacktrace?
         t.printStackTrace();
         if(t instanceof Exception)
         {
            Exception e = (Exception) t;
            RmiIdlUtil.rethrowIfCorbaSystemException(e);
            out = (org.omg.CORBA_2_3.portable.OutputStream) handler.createExceptionReply();
            op.writeException(out, e);
         }
         else
            throw new RuntimeException("NYI");
      }
      return out;
   
private javax.transaction.TransactionManagergetTransactionManager()

      //return TxUtil.getTransactionManager();
      return TransactionManagerLocator.getInstance().locate();
   
private java.lang.Objectinvoke(java.lang.Object id, java.lang.reflect.Method method, java.lang.Object[] args)

      // TODO: Support other containers beside Stateless and Stateful?
      return ((SessionContainer) container).invoke(factory, id, method, args, null);
   
private java.lang.Objectinvoke(javax.transaction.Transaction tx, java.lang.Object id, java.lang.reflect.Method method, java.lang.Object[] args)

      if(tx == null)
         return invoke(id, method, args);
      
      // FIXME: refactor TxServerInterceptor so that it pushed the tpc into the invocation like ClientTxPropegationInterceptor
      // this would require the localInvoke to be also refactored, so that it uses invocation instead of localInvoke.
      TransactionManager tm = getTransactionManager();
      
      // see TxPropagationInterceptor
      if(tm.getTransaction() != null)
         throw new RuntimeException("cannot import a transaction context when a transaction is already associated with the thread");
      tm.resume(tx);
      try
      {
         return invoke(id, method, args);
      }
      finally
      {
         tm.suspend();
      }