UndeployActionpublic class UndeployAction extends com.sun.enterprise.deployapi.ProgressObjectImpl
| Fields Summary |
|---|
| private com.sun.appserv.management.deploy.DeploymentMgr | deplMgr | | private static com.sun.enterprise.util.i18n.StringManager | localStrings |
| Methods Summary |
|---|
| private boolean | isDefaultWebModule(com.sun.enterprise.deployapi.SunTarget domain, com.sun.appserv.management.client.ConnectionSource dasConnection, java.lang.String moduleID)
try {
DomainConfig cfg = ProxyFactory.getInstance(dasConnection).getDomainRoot().getDomainConfig();
Map cfgcfg = cfg.getConfigConfigMap();
for(Iterator it1 = cfgcfg.keySet().iterator(); it1.hasNext(); ) {
ConfigConfig cf1 = (ConfigConfig) cfgcfg.get(it1.next());
HTTPServiceConfig httpSvc = cf1.getHTTPServiceConfig();
Map vsMap = httpSvc.getVirtualServerConfigMap();
for(Iterator it2 = vsMap.keySet().iterator(); it2.hasNext(); ) {
VirtualServerConfig vs = (VirtualServerConfig) vsMap.get(it2.next());
if(moduleID.equals(vs.getDefaultWebModule())) {
setupForAbnormalExit(
localStrings.getString("enterprise.deployment.client.def_web_module_refs_exist", moduleID), domain);
return true;
}
}
}
} catch (Throwable ioex) {
finalDeploymentStatus.setStageException(ioex);
setupForAbnormalExit(localStrings.getString("enterprise.deployment.client.undeploy_application_failed", ioex.getMessage()), domain);
return true;
}
return false;
| | public void | run()
ConnectionSource dasConnection= (ConnectionSource) args[0];
String moduleID = (String) args[1];
Map deployOptions = (Map) args[2];
SunTarget[] targetList = (SunTarget[]) args[3];
SunTarget domain = (SunTarget) args[4];
boolean isLocalConnectionSource = ((Boolean) args[5]).booleanValue();
try {
// First check if this module is a web module and if so, it is a default web module
if((DeploymentClientUtils.getModuleType(dasConnection.getExistingMBeanServerConnection(), moduleID)
== ModuleType.WAR) &&
(isDefaultWebModule(domain, dasConnection, moduleID))) {
return;
}
deplMgr = ProxyFactory.getInstance(dasConnection).getDomainRoot().getDeploymentMgr();
// Get list of all targets on which this module is already deployed
Map deployedTargets = DeploymentClientUtils.getDeployedTargetList(dasConnection, moduleID);
// the target module ids in which the operation was successful
ArrayList resultTargetModuleIDs = new ArrayList();
// if there is already app ref associated with this app
if (deployedTargets.size() > 0) {
// if it's undeploy from domain, then it's equivalent
// to undeploy from all targets
if ((TargetType.DOMAIN.equals(targetList[0].getName()))) {
DeploymentFacility deploymentFacility;
if(isLocalConnectionSource) {
deploymentFacility = DeploymentFacilityFactory.getLocalDeploymentFacility();
} else {
deploymentFacility = DeploymentFacilityFactory.getDeploymentFacility();
}
deploymentFacility.connect(
targetList[0].getConnectionInfo());
Set nameSet = deployedTargets.keySet();
String[] targetNames = (String[])nameSet.toArray(
new String[nameSet.size()]);
Target[] targetList2 =
deploymentFacility.createTargets(targetNames);
if (targetList2 == null) {
setupForAbnormalExit(localStrings.getString("enterprise.deployment.client.createTargetsFailed"), domain);
return;
}
targetList = new SunTarget[targetList2.length];
for (int ii = 0; ii < targetList2.length; ii++) {
targetList[ii] = (SunTarget)targetList2[ii];
}
}
// if all targets on which the app is deployed is not given,
// return error
else if (!DeploymentClientUtils.isTargetListComplete(deployedTargets, targetList)) {
setupForAbnormalExit(
localStrings.getString("enterprise.deployment.client.specifyAllTargets", moduleID, "undeploy"),
domain);
return;
}
// First stop all apps and remove all app references
RollBackAction rollback = new RollBackAction(RollBackAction.DELETE_APP_REF_OPERATION,
moduleID, deployOptions);
deployOptions.put(DeploymentProperties.DEPLOY_OPTION_FORCE_KEY, "false");
for(int i=0; i<targetList.length; i++) {
// We dont rollback for stop failure because the failure may be because of server being down
// We just add DeploymentStatus of this phase to the complete DeploymentStatus
DeploymentClientUtils.setResourceOptions(
deployOptions,
DeploymentProperties.RES_UNDEPLOYMENT,
targetList[i].getName());
DeploymentStatus stat = DeploymentClientUtils.stopApplication(
dasConnection.getExistingMBeanServerConnection(),
moduleID, targetList[i], deployOptions);
if (!checkStatusAndAddStage(targetList[i], null,
localStrings.getString("enterprise.deployment.client.undeploy_stop", targetList[i].getName()), dasConnection, stat)) {
return;
}
stat = DeploymentClientUtils.deleteApplicationReference(
dasConnection.getExistingMBeanServerConnection(),
moduleID, targetList[i], deployOptions);
if(!checkStatusAndAddStage(targetList[i], rollback,
localStrings.getString("enterprise.deployment.client.undeploy_remove_ref", targetList[i].getName()), dasConnection, stat)) {
return;
}
rollback.addTarget(targetList[i], RollBackAction.APP_REF_DELETED);
resultTargetModuleIDs.add(new SunTargetModuleID(moduleID, targetList[i]));
}
}
// if undeploy from "domain" with no existing application-ref
if ((TargetType.DOMAIN.equals(targetList[0].getName()))) {
DeploymentClientUtils.setResourceOptions(
deployOptions,
DeploymentProperties.RES_UNDEPLOYMENT,
targetList);
} else {
DeploymentClientUtils.setResourceOptions(
deployOptions,
DeploymentProperties.RES_NO_OP,
targetList);
}
// Call DeploymentMgr to start undeploy
fireProgressEvent(StateType.RUNNING, localStrings.getString("enterprise.deployment.client.undeploying"), domain);
Map undeployStatus = deplMgr.undeploy(moduleID, deployOptions);
com.sun.appserv.management.deploy.DeploymentStatus finalStatusFromMBean =
DeploymentSupport.mapToDeploymentStatus(undeployStatus);
DeploymentStatus tmp = DeploymentClientUtils.getDeploymentStatusFromAdminStatus(finalStatusFromMBean);
if(!checkStatusAndAddStage(domain, null, localStrings.getString("enterprise.deployment.client.undeploy_from_domain"), dasConnection, tmp)) {
return;
}
// undeploy over - add this to the result target module ID
resultTargetModuleIDs.add(new SunTargetModuleID(moduleID, domain));
// initialize the instance variable targetModuleIDs using
// the successful module ids
this.targetModuleIDs = new TargetModuleID[resultTargetModuleIDs.size()];
this.targetModuleIDs =
(TargetModuleID[])resultTargetModuleIDs.toArray(this.targetModuleIDs);
setupForNormalExit(localStrings.getString("enterprise.deployment.client.undeploy_application", moduleID), domain);
} catch (Throwable ioex) {
finalDeploymentStatus.setStageException(ioex);
setupForAbnormalExit(localStrings.getString("enterprise.deployment.client.undeploy_application_failed", ioex.getMessage()), domain);
return;
}
|
|
