FileDocCategorySizeDatePackage
Remote30WrapperGenerator.javaAPI DocGlassfish v2 API15018Tue Jun 19 20:35:06 BST 2007com.sun.ejb.codegen

Remote30WrapperGenerator

public class Remote30WrapperGenerator extends Generator implements ClassGeneratorFactory

Fields Summary
private static com.sun.enterprise.util.LocalStringManagerImpl
localStrings
private static Logger
_logger
private String
remoteInterfaceName
private Class
businessInterface
private String
remoteClientClassName
private String
remoteClientPackageName
private String
remoteClientSimpleName
private Method[]
bizMethods
private ClassLoader
loader
Constructors Summary
public Remote30WrapperGenerator(ClassLoader cl, String businessIntfName, String remoteIntfName)
Construct the Wrapper generator with the specified deployment descriptor and class loader.

exception
GeneratorException.

	super();

        remoteInterfaceName = remoteIntfName;

        loader = cl;

	try {
	    this.businessInterface = cl.loadClass(businessIntfName);
	} catch (ClassNotFoundException ex) {
	    throw new InvalidBean(
		localStrings.getLocalString(
		"generator.remote_interface_not_found",
		"Business interface " + businessInterface + " not found "));
	}

        if( javax.ejb.EJBObject.class.isAssignableFrom(businessInterface) ) {
            throw new GeneratorException("Invalid Remote Business Interface " +
                 businessInterface + ". A Remote Business interface MUST " +
                 "not extend javax.ejb.EJBObject.");
        }

        remoteClientClassName = EJBUtils.
            getGeneratedRemoteWrapperName(businessInterface.getName());

        remoteClientPackageName = getPackageName(remoteClientClassName);
        remoteClientSimpleName = getBaseName(remoteClientClassName);

	bizMethods = removeDups(businessInterface.getMethods());

        // NOTE : no need to remove ejb object methods because EJBObject
        // is only visible through the RemoteHome view.
Methods Summary
public java.lang.StringclassName()

        return getGeneratedClass();
public com.sun.corba.ee.impl.codegen.ClassGeneratorevaluate()


        _clear();

        if (remoteClientPackageName != null) {
	    _package(remoteClientPackageName);
        } else {
            // no-arg _package() call is required for default package
            _package();
        }

        _class(PUBLIC, remoteClientSimpleName, 
               _t("com.sun.ejb.containers.RemoteBusinessWrapperBase"), 
               _t(businessInterface.getName()));
        
        _data(PRIVATE, _t(remoteInterfaceName), "delegate_");

        _constructor( PUBLIC ) ;
        _arg(_t(remoteInterfaceName), "stub");
        _arg(_String(), "busIntf");

        _body();
        _expr(_super(_s(_void(), _t("java.rmi.Remote"), _String()),
                     _v("stub"), _v("busIntf"))) ;
        _assign(_v("delegate_"), _v("stub"));
        _end();

        for(int i = 0; i < bizMethods.length; i++) {
	    printMethodImpl(bizMethods[i]);
	}

        _end();

        /*
        System.out.println("Generating byte code for remote30rwappergen");
        try {
            java.util.Properties p = new java.util.Properties();
            p.put("Wrapper.DUMP_AFTER_SETUP_VISITOR", "true");
            p.put("Wrapper.TRACE_BYTE_CODE_GENERATION", "true");
            p.put("Wrapper.USE_ASM_VERIFIER", "true");
            _byteCode(loader, null, p);
        } catch(Exception e) {
            System.out.println("Got exception when generating byte code");
            e.printStackTrace();
        }
        */

        return _classGenerator() ;
public voidgenerate(java.io.OutputStream out)
Generate the code to the specified output stream.

param
the output stream
exception
GeneratorException on a generation error
exception
IOException on an IO error

	IndentingWriter p = new IndentingWriter(new OutputStreamWriter(out));

	if (remoteClientPackageName != null) {
	    p.pln("package " + remoteClientPackageName + ";");
        }

	p.plnI("public final class " + remoteClientSimpleName + 
           " extends com.sun.ejb.containers.RemoteBusinessWrapperBase" + 
           " implements " + businessInterface.getName() + " {");

	p.pln("");
        p.pln("private " + remoteInterfaceName + " delegate_;");
	p.pln("");

	// this is the constructor
	p.plnI("public " + remoteClientSimpleName + "(" +
               remoteInterfaceName + " stub" + " , " + 
               "java.lang.String busIntf" + ")" + " {");
        p.pln("super(stub, busIntf);");
	p.pln("");
        p.pln("delegate_ = stub;");
	p.pOln("}");
        p.pln("");

	// each remote method
	for(int i = 0; i < bizMethods.length; i++) {
	    printMethodImpl(p, bizMethods[i]);
	}

	p.pOln("}");
	p.close();
public java.lang.StringgetGeneratedClass()

        return remoteClientClassName;
private voidprintMethodImpl(java.lang.reflect.Method m)


        List<Type> exceptionList = new LinkedList<Type>();
	for(Class exception : m.getExceptionTypes()) {
            exceptionList.add(Type.type(exception));
	}

        _method( PUBLIC, Type.type(m.getReturnType()),
                 m.getName(), exceptionList);

        int i = 0;
        List<Type> expressionListTypes = new LinkedList<Type>();
        List<Expression> expressionList = new LinkedList<Expression>();
        for(Class param : m.getParameterTypes()) {
            String paramName = "param" + i;
            _arg(Type.type(param), paramName);
            i++;
            expressionListTypes.add(Type.type(param));
            expressionList.add(_v(paramName));
	}

        _body();


        _try();

        Class returnType = m.getReturnType();

        if( returnType == void.class ) {
            _expr( _call( _v("delegate_"), m.getName(), 
                          _s(Type.type(returnType), expressionListTypes), 
                          expressionList));
        } else {
            _return( _call( _v("delegate_"), m.getName(), 
                            _s(Type.type(returnType), expressionListTypes), 
                            expressionList) );
        }

        boolean doExceptionTranslation = 
            !java.rmi.Remote.class.isAssignableFrom(businessInterface);
        if( doExceptionTranslation ) {

            _catch( _t("javax.transaction.TransactionRolledbackException"),
                    "trex");

                _define( _t("java.lang.RuntimeException"), "r", 
                         _new( _t("javax.ejb.EJBTransactionRolledbackException"), 
                           _s(_void())));
                _expr( _call( _v("r"), "initCause",
                              _s(_t("java.lang.Throwable"), 
                                 _t("java.lang.Throwable")), 
                              _v("trex")));
                _throw(_v("r"));

            _catch( _t("javax.transaction.TransactionRequiredException"),
                    "treqex");

                _define( _t("java.lang.RuntimeException"), "r", 
                         _new( _t("javax.ejb.EJBTransactionRequiredException"), 
                           _s(_void())));
                _expr( _call( _v("r"), "initCause",
                              _s(_t("java.lang.Throwable"), 
                                 _t("java.lang.Throwable")), 
                              _v("treqex")));
                _throw(_v("r"));

            _catch( _t("java.rmi.NoSuchObjectException"),
                    "nsoe");

                _define( _t("java.lang.RuntimeException"), "r", 
                         _new( _t("javax.ejb.NoSuchEJBException"), 
                           _s(_void())));
                _expr( _call( _v("r"), "initCause",
                              _s(_t("java.lang.Throwable"), 
                                 _t("java.lang.Throwable")), 
                              _v("nsoe")));
                _throw(_v("r"));

            _catch(_t("com.sun.ejb.containers.InternalEJBContainerException"),
                   "iejbcEx");
            // There's only one kind of InternalEJBContainerException, so
            // we know it's a ParallelAccessException
            _define(_t("com.sun.ejb.containers.ParallelAccessException"),
                    "paEx", 
                    _cast(_t("com.sun.ejb.containers.ParallelAccessException"),
                          _v("iejbcEx")));
                    
                _define(_t("javax.ejb.ConcurrentAccessException"), "r", _new(
                        _t("javax.ejb.ConcurrentAccessException"), _s(_void())));
                _expr(_call(_v("r"), "initCause", _s(_t("java.lang.Throwable"),
                        _t("java.lang.Throwable")), _v("paEx")));
                _throw(_v("r"));

            _catch( _t("java.rmi.RemoteException"), "re");
            
                _throw( _new( _t("javax.ejb.EJBException"), 
                              _s(_void(), _t("java.lang.Exception")), 
                              _v("re")));
            
            _catch( _t("org.omg.CORBA.SystemException"), "corbaSysEx");
                _define( _t("java.lang.RuntimeException"), "r", 
                         _new( _t("javax.ejb.EJBException"), 
                           _s(_void())));
                _expr( _call( _v("r"), "initCause",
                              _s(_t("java.lang.Throwable"), 
                                 _t("java.lang.Throwable")), 
                              _v("corbaSysEx")));
                _throw(_v("r"));

            _end();

        } else {
            _catch(_t("com.sun.ejb.containers.InternalEJBContainerException"), "iejbcEx");
                _throw( _new( _t("com.sun.ejb.containers.InternalRemoteException"), 
                              _s(_void(), _t("com.sun.ejb.containers.InternalEJBContainerException")), 
                              _v("iejbcEx")));
            _end();
        }

        _end();
private voidprintMethodImpl(sun.rmi.rmic.IndentingWriter p, java.lang.reflect.Method m)
Generate the code for a single method.

param
the writer.
param
the method to generate code for.
exception
IOException.


	// print method signature and exceptions
	p.p("public " + printType(m.getReturnType()) + " "
		+ m.getName() + "(");
	Class[] params = m.getParameterTypes();
	for(int i = 0; i < params.length; i++) {
	    if (i != 0)
		p.p(", ");
	    p.p(printType(params[i]) + " param" + i);
	}
	p.p(") ");
	Class[] exceptions = m.getExceptionTypes();
	for(int i = 0; i < exceptions.length; i++) {
	    if (i == 0)
		p.p("throws ");
	    else
		p.p(", ");
	    p.p(exceptions[i].getName());
	}
	p.plnI("{");

        if( !java.rmi.Remote.class.isAssignableFrom(businessInterface) ) {
            p.pln("try {");
        }

        if (m.getReturnType() != void.class) {
            p.p("    return ");
	}

	// print code for calling biz method on bean class

	p.p("    delegate_." + m.getName() + "(");
	for(int i = 0; i < params.length; i++) {
            if( i != 0 ) {
                p.p(" , ");
            }
            p.p("param" + i);
	}
        p.pln(");");

        if( !java.rmi.Remote.class.isAssignableFrom(businessInterface) ) {
            
            p.pln("} catch(javax.transaction.TransactionRolledbackException trex) {");
            p.pln("\tjava.lang.RuntimeException r =  new javax.ejb.EJBTransactionRolledbackException();");
            p.pln("\tr.initCause(trex);");
            p.pln("\tthrow r;");

            p.pln("} catch(java.rmi.NoSuchObjectException nsoe) {");
            p.pln("\tjava.lang.RuntimeException r =  new javax.ejb.NoSuchEJBException();");
            p.pln("\tr.initCause(nsoe);");
            p.pln("\tthrow r;");

            p.pln("} catch(javax.transaction.TransactionRequiredException txre) {");
            p.pln("\tjava.lang.RuntimeException r =  new javax.ejb.EJBTransactionRequiredException();");
            p.pln("\tr.initCause(txre);");
            p.pln("\tthrow r;");

            p.pln("} catch(java.rmi.RemoteException re) {");
            p.pln("\tthrow new javax.ejb.EJBException(re);");
            p.pln("} ");

        }

        p.pln("");
	p.pOln("} ");
        p.pln("");