ActiveOutboundResourceAdapterpublic class ActiveOutboundResourceAdapter extends Object implements ActiveResourceAdapter| This class represents the abstraction of a 1.0 complient rar.
It holds the ra.xml (connector decriptor) values, class loader used to
to load the Resource adapter class and managed connection factory and
module name (rar) to which it belongs.
It is also the base class for ActiveInboundResourceAdapter(a 1.5 complient
rar). |
| Fields Summary |
|---|
| protected ConnectorDescriptor | desc_ | | protected String | moduleName_ | | protected ClassLoader | jcl_ | | protected ConnectionDefDescriptor[] | connectionDefs_ | | protected ConnectorRuntime | connectorRuntime_ | | static Logger | _logger | | private com.sun.enterprise.util.i18n.StringManager | localStrings |
| Constructors Summary |
|---|
public ActiveOutboundResourceAdapter(ConnectorDescriptor desc, String moduleName, ClassLoader jcl)Constructor.
this.desc_ = desc;
moduleName_ = moduleName;
jcl_ = jcl;
connectorRuntime_ = ConnectorRuntime.getRuntime();
connectionDefs_ = ConnectorDDTransformUtils. getConnectionDefs(desc_);
|
| Methods Summary |
|---|
| protected void | createAllConnectorResources()Creates both the default connector connection pools and resources
try {
if (desc_.getSunDescriptor() != null &&
desc_.getSunDescriptor().getResourceAdapter() != null) {
// sun-ra.xml exists
String jndiName = (String)desc_.getSunDescriptor().
getResourceAdapter().getValue(ResourceAdapter.JNDI_NAME);
if (jndiName == null || jndiName.equals("")) {
// jndiName is empty, do not create duplicate pools, use setting in sun-ra.xml
createDefaultConnectorConnectionPools(true);
} else {
// jndiName is not empty, so create duplicate pools, both default and sun-ra.xml
createSunRAConnectionPool();
createDefaultConnectorConnectionPools(false);
}
} else {
// sun-ra.xml doesn't exist, so create default pools
createDefaultConnectorConnectionPools(false);
}
// always create default connector resources
createDefaultConnectorResources();
} catch (ConnectorRuntimeException cre) {
//Connector deployment should _not_ fail if default connector
//connector pool and resource creation fails.
_logger.log(Level.SEVERE,"rardeployment.defaultpoolresourcecreation.failed",
cre);
_logger.log(Level.FINE, "Error while trying to create the default connector" +
"connection pool and resource", cre);
}
| | protected void | createDefaultConnectorConnectionPools(boolean useSunRA)Creates default connector connection pool
for(int i = 0;i < connectionDefs_.length;++i) {
String poolName = connectorRuntime_.getDefaultPoolName(
moduleName_,
connectionDefs_[i].getConnectionFactoryIntf());
ConnectorDescriptorInfo connectorDescriptorInfo =
ConnectorDDTransformUtils.getConnectorDescriptorInfo(
connectionDefs_[i]);
connectorDescriptorInfo.setRarName(moduleName_);
connectorDescriptorInfo.setResourceAdapterClassName(
desc_.getResourceAdapterClass());
ConnectorConnectionPool connectorPoolObj;
// if useSunRA is true, then create connectorPoolObject using settings
// from sunRAXML
if (useSunRA) {
connectorPoolObj =
ConnectionPoolObjectsUtils.createSunRaConnectorPoolObject(poolName, desc_, moduleName_);
} else {
connectorPoolObj =
ConnectionPoolObjectsUtils.createDefaultConnectorPoolObject(poolName, moduleName_);
}
connectorPoolObj.setConnectorDescriptorInfo(
connectorDescriptorInfo );
connectorRuntime_.createConnectorConnectionPool(connectorPoolObj);
_logger.log(Level.FINE,"Created default connection pool : ",
poolName);
}
| | protected void | createDefaultConnectorResources()Creates default connector resource
for(int i=0; i<connectionDefs_.length;++i) {
String connectionDefName =
connectionDefs_[i].getConnectionFactoryIntf();
String resourceName = connectorRuntime_.getDefaultResourceName(
moduleName_,
connectionDefName);
String poolName = connectorRuntime_.getDefaultPoolName(
moduleName_,
connectionDefName);
connectorRuntime_.createConnectorResource(
resourceName,poolName,null);
_logger.log(Level.FINE,"Created default connector resource : ",
resourceName);
}
| | public ManagedConnectionFactory[] | createManagedConnectionFactories(ConnectorConnectionPool ccp, java.lang.ClassLoader jcl)Creates managed Connection factories corresponding to one pool.
This should be implemented in the ActiveJmsResourceAdapter, for
jms resources, has been implemented to perform xa resource recovery
in mq clusters, not supported for any other code path.
throw new UnsupportedOperationException("This operation is not supported");
| | public ManagedConnectionFactory | createManagedConnectionFactory(ConnectorConnectionPool ccp, java.lang.ClassLoader jcl)Creates managed Connection factory instance.
final String mcfClass = ccp.getConnectorDescriptorInfo().
getManagedConnectionFactoryClass();
try {
ManagedConnectionFactory mcf = null;
if (moduleName_.equals(ConnectorRuntime.DEFAULT_JMS_ADAPTER)) {
Object tmp = AccessController.doPrivileged(
new PrivilegedExceptionAction() {
public Object run() throws Exception{
return instantiateMCF(mcfClass);
}
});
mcf = (ManagedConnectionFactory) tmp;
} else {
mcf = instantiateMCF(mcfClass);
}
if (mcf instanceof ConfigurableTransactionSupport) {
TransactionSupport ts =
ConnectionPoolObjectsUtils.getTransactionSupport(
ccp.getTransactionSupport());
((ConfigurableTransactionSupport)mcf).setTransactionSupport(ts);
}
SetMethodAction setMethodAction = new SetMethodAction(mcf,
ccp.getConnectorDescriptorInfo().getMCFConfigProperties());
setMethodAction.run();
_logger.log(Level.FINE,"Created MCF object : ",mcfClass);
return mcf;
} catch (PrivilegedActionException ex) {
_logger.log(Level.SEVERE,
"rardeployment.privilegedaction_error",
new Object[]{mcfClass, ex.getException().getMessage()});
_logger.log(Level.FINE,
"rardeployment.privilegedaction_error",
ex.getException());
return null;
} catch (ClassNotFoundException Ex) {
_logger.log(Level.SEVERE,"rardeployment.class_not_found",
new Object[]{mcfClass, Ex.getMessage()});
_logger.log(Level.FINE,"rardeployment.class_not_found",
Ex);
return null;
} catch (InstantiationException Ex) {
_logger.log(Level.SEVERE,
"rardeployment.class_instantiation_error",
new Object[]{mcfClass, Ex.getMessage()});
_logger.log(Level.FINE,
"rardeployment.class_instantiation_error",
Ex);
return null;
} catch (IllegalAccessException Ex) {
_logger.log(Level.SEVERE,
"rardeployment.illegalaccess_error",
new Object[]{mcfClass, Ex.getMessage()});
_logger.log(Level.FINE,
"rardeployment.illegalaccess_error",
Ex);
return null;
} catch (Exception Ex) {
_logger.log(Level.SEVERE,"rardeployment.mcfcreation_error",
new Object[]{mcfClass, Ex.getMessage()});
_logger.log(Level.FINE,"rardeployment.mcfcreation_error",
Ex);
return null;
}
| | public void | createSunRAConnectionPool()Creates connector connection pool pertaining to sun-ra.xml. This is
only for 1.0 complient rars.
String defaultPoolName = connectorRuntime_.getDefaultPoolName(
moduleName_,connectionDefs_[0].getConnectionFactoryIntf());
String sunRAPoolName = defaultPoolName+ConnectorConstants.SUN_RA_POOL;
ConnectorDescriptorInfo connectorDescriptorInfo =
ConnectorDDTransformUtils.getConnectorDescriptorInfo(
connectionDefs_[0]);
connectorDescriptorInfo.setRarName(moduleName_);
connectorDescriptorInfo.setResourceAdapterClassName(
desc_.getResourceAdapterClass());
ConnectorConnectionPool connectorPoolObj =
ConnectionPoolObjectsUtils.createSunRaConnectorPoolObject(
sunRAPoolName,desc_,moduleName_);
connectorPoolObj.setConnectorDescriptorInfo(
connectorDescriptorInfo );
connectorRuntime_.createConnectorConnectionPool(connectorPoolObj);
_logger.log(Level.FINE,"Created SUNRA connection pool:",sunRAPoolName);
String jndiName = (String)desc_.getSunDescriptor().
getResourceAdapter().getValue(ResourceAdapter.JNDI_NAME);
connectorRuntime_.createConnectorResource(jndiName,sunRAPoolName,null);
_logger.log(Level.FINE,"Created SUNRA connector resource : ",
jndiName);
| | protected void | deleteDefaultConnectorConnectionPools()Deletes the default connector connection pools.
for(int i=0;i<connectionDefs_.length;++i) {
String connectionDefName =
connectionDefs_[i].getConnectionFactoryIntf();
String resourceJndiName = connectorRuntime_.getDefaultPoolName(
moduleName_,
connectionDefName);
try {
connectorRuntime_.deleteConnectorConnectionPool(
resourceJndiName);
} catch(ConnectorRuntimeException cre) {
_logger.log(Level.WARNING,
"rar.undeployment.default_resource_delete_fail",
resourceJndiName);
}
}
| | protected void | deleteDefaultConnectorResources()Deletes the default connector resources.
for(int i=0;i<connectionDefs_.length;++i) {
String connectionDefName =
connectionDefs_[i].getConnectionFactoryIntf();
String resourceJndiName = connectorRuntime_.getDefaultResourceName(
moduleName_,
connectionDefName);
try {
connectorRuntime_.deleteConnectorResource(resourceJndiName);
} catch(ConnectorRuntimeException cre) {
_logger.log(Level.WARNING,
"rar.undeployment.default_resource_delete_fail",
resourceJndiName);
_logger.log(Level.FINE, "Error while trying to delete the default " +
"connector resource", cre);
}
}
| | public void | deleteSunRAConnectionPool()Added to clean up the connector connection pool pertaining to sun-ra.xml. This is
only for 1.0 complient rars.
String defaultPoolName = connectorRuntime_.getDefaultPoolName(
moduleName_,connectionDefs_[0].getConnectionFactoryIntf());
String sunRAPoolName = defaultPoolName+ConnectorConstants.SUN_RA_POOL;
try {
connectorRuntime_.deleteConnectorConnectionPool(
sunRAPoolName);
} catch(ConnectorRuntimeException cre) {
_logger.log(Level.WARNING,
"rar.undeployment.default_resource_delete_fail",
sunRAPoolName);
}
| | public void | destroy()uninitializes the resource adapter. It also destroys the default pools
and resources
if(isServer()) {
destroyAllConnectorResources();
}
| | protected void | destroyAllConnectorResources()Deletes both the default connector connection pools and resources
if(!(ResourcesUtil.createInstance().belongToSystemRar(moduleName_))){
deleteDefaultConnectorResources();
deleteDefaultConnectorConnectionPools();
// Added to ensure clean-up of the Sun RA connection pool
if (desc_.getSunDescriptor() != null &&
desc_.getSunDescriptor().getResourceAdapter() != null) {
// sun-ra.xml exists
String jndiName = (String)desc_.getSunDescriptor().
getResourceAdapter().getValue(ResourceAdapter.JNDI_NAME);
if (jndiName == null || jndiName.equals("")) {
// jndiName is empty, sunRA pool not created, so don't need to delete
} else {
// jndiName is not empty, need to delete pool
deleteSunRAConnectionPool();
}
}
}
| | public java.lang.ClassLoader | getClassLoader()Returns the class loader that is used to load the RAR.
return jcl_;
| | public ConnectorDescriptor | getDescriptor()Returns the Connector descriptor which represents/holds ra.xml
return desc_;
| | public java.lang.String | getModuleName()
return moduleName_;
| | private ManagedConnectionFactory | instantiateMCF(java.lang.String mcfClass)
if(jcl_ != null) {
return (ManagedConnectionFactory)jcl_.loadClass(
mcfClass).newInstance();
} else {
return (ManagedConnectionFactory) Class.forName(
mcfClass).newInstance();
}
| | protected boolean | isServer()Check if the execution environment is appserver runtime or application
client container.
if(connectorRuntime_.getEnviron() == ConnectorConstants.SERVER) {
return true;
} else {
return false;
}
| | public void | setup()It initializes the resource adapter. It also creates the default pools
and resources of all the connection definitions.
if(connectionDefs_ == null ||
connectionDefs_.length != 1) {
_logger.log(Level.SEVERE,"rardeployment.invalid_connector_desc",
moduleName_);
String i18nMsg = localStrings.getString(
"ccp_adm.invalid_connector_desc");
throw new ConnectorRuntimeException( i18nMsg );
}
ResourcesUtil resUtil = ResourcesUtil.createInstance();
if(isServer() && !resUtil.belongToSystemRar(moduleName_)) {
createAllConnectorResources();
}
_logger.log(Level.FINE,
"Completed Active Resource adapter setup", moduleName_);
|
|
