TxSecIORInterceptorpublic class TxSecIORInterceptor extends org.omg.CORBA.LocalObject implements org.omg.PortableInterceptor.IORInterceptor
| Fields Summary |
|---|
| private static Logger | _logger | | private org.omg.IOP.Codec | codec |
| Methods Summary |
|---|
| private void | addCSIv2Components(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 void | addOTSComponents(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 void | destroy()
| | public void | establish_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.String | name()
return "TxSecIORInterceptor";
|
|
