FileDocCategorySizeDatePackage
TxSecIORInterceptor.javaAPI DocGlassfish v2 API7583Fri May 04 22:34:56 BST 2007com.sun.enterprise.iiop

TxSecIORInterceptor

public class TxSecIORInterceptor extends LocalObject implements IORInterceptor

Fields Summary
private static Logger
_logger
private Codec
codec
Constructors Summary
public TxSecIORInterceptor(Codec c)

        codec = c;
    
Methods Summary
private voidaddCSIv2Components(org.omg.PortableInterceptor.IORInfo iorInfo, com.sun.enterprise.deployment.EjbDescriptor desc)

      try {
	if(_logger.isLoggable(Level.FINE)) {
	    _logger.log(Level.FINE, 
			".addCSIv2Components->: "
			+ " " + iorInfo + " " + desc );
	}

        if (ASORBUtilities.isGMSAvailableAndClusterHeartbeatEnabled()) {
	    // If this app server instance is part of a dynamic cluster (that is,
	    // one that supports RMI-IIOP failover and load balancing, DO NOT
	    // create the CSIv2 components here.  Instead, handle this in the
	    // ORB's ServerGroupManager, in conjunctions with the 
	    // CSIv2SSLTaggedComponentHandler.
            return;
        }

	if(_logger.isLoggable(Level.FINE)) {
	    _logger.log(Level.FINE, 
			".addCSIv2Components: desc: " + desc);
	}

	ORB orb = ORBManager.getORB();

	int sslMutualAuthPort = -1;
	try {
	    sslMutualAuthPort = ((com.sun.corba.ee.spi.legacy.interceptor.IORInfoExt)iorInfo).
								getServerPort("SSL_MUTUALAUTH");
	} catch (com.sun.corba.ee.spi.legacy.interceptor.UnknownType ute) {
            _logger.log(Level.FINE,"UnknownType exception", ute);
	}

	if(_logger.isLoggable(Level.FINE)) {
	    _logger.log(Level.FINE, 
			".addCSIv2Components: sslMutualAuthPort: " 
			+ sslMutualAuthPort);
	}

	CSIV2TaggedComponentInfo ctc = new CSIV2TaggedComponentInfo( orb,
	    sslMutualAuthPort );

	// Create CSIv2 tagged component
	int sslport = -1;
	try {
	    sslport = ((com.sun.corba.ee.spi.legacy.interceptor.IORInfoExt)iorInfo).
								getServerPort("SSL");
	} catch (com.sun.corba.ee.spi.legacy.interceptor.UnknownType ute) {
            _logger.log(Level.FINE,"UnknownType exception", ute);
	}

	if(_logger.isLoggable(Level.FINE)) {
	    _logger.log(Level.FINE, 
			".addCSIv2Components: sslport: " 
			+ sslport);
	}

	TaggedComponent csiv2Comp = null;
	if ( desc != null ) {
	    csiv2Comp = ctc.createSecurityTaggedComponent(sslport, desc);
	} else { 
	    // this is not an EJB object, must be a non-EJB CORBA object
	    csiv2Comp = ctc.createSecurityTaggedComponent(sslport);
	}

	iorInfo.add_ior_component(csiv2Comp);

      } finally {
	  if(_logger.isLoggable(Level.FINE)) {
	      _logger.log(Level.FINE,
			  ".addCSIv2Components<-: "
			  + " " + iorInfo + " " + desc);
	  }
      }
    
private voidaddOTSComponents(org.omg.PortableInterceptor.IORInfo iorInfo)

       
        short invPolicyValue = SHARED.value;
        short otsPolicyValue = ADAPTS.value;            
        
        Any otsAny = ORB.init().create_any();
        Any invAny = ORB.init().create_any();
        
        otsAny.insert_short(otsPolicyValue);
        invAny.insert_short(invPolicyValue);
        
        byte[] otsCompValue = null;
        byte[] invCompValue = null;                 
        try {
            otsCompValue = codec.encode_value(otsAny);
            invCompValue = codec.encode_value(invAny);
        } catch (org.omg.IOP.CodecPackage.InvalidTypeForEncoding e) {
            throw new INTERNAL("InvalidTypeForEncoding "+e.getMessage());
        }
    
        TaggedComponent otsComp = new TaggedComponent(TAG_OTS_POLICY.value,
                                                      otsCompValue);
	iorInfo.add_ior_component(otsComp);

        TaggedComponent invComp = new TaggedComponent(TAG_INV_POLICY.value,
                                                      invCompValue);
	iorInfo.add_ior_component(invComp);
    
public voiddestroy()

    
public voidestablish_components(org.omg.PortableInterceptor.IORInfo iorInfo)

        try {
	    _logger.log(Level.FINE, 
			"TxSecIORInterceptor.establish_components->:");

	    // Add OTS tagged components. These are always the same for all EJBs
	    OTSPolicy otsPolicy = null;
	    try {
		otsPolicy = (OTSPolicy)iorInfo.get_effective_policy(
				   POARemoteReferenceFactory.OTS_POLICY_TYPE);
	    } catch ( INV_POLICY ex ) {
		_logger.log(Level.FINE, 
			    "TxSecIORInterceptor.establish_components: OTSPolicy not present");
	    }
	    if ( otsPolicy != null ) {
		addOTSComponents(iorInfo);
	    }

	    EjbDescriptor desc = CSIV2TaggedComponentInfo.getEjbDescriptor( iorInfo ) ;
	    addCSIv2Components(iorInfo, desc);
        } catch (Exception e) {
            _logger.log(Level.WARNING,"Exception in establish_components", e);
        } finally {
	    _logger.log(Level.FINE, 
			"TxSecIORInterceptor.establish_components<-:");
	}
    
public java.lang.Stringname()

        return "TxSecIORInterceptor";