Skip to content
This repository has been archived by the owner on Apr 5, 2022. It is now read-only.

Commit

Permalink
Fix stream failover
Browse files Browse the repository at this point in the history
- Fix deployment handling in DepartedContainerModuleRedeployer
  so that modules in a same stream and same container will
  actually get re-deployed.
- Bug was a wrong if clause position regarding stream caching.
- Fixes #1924
  • Loading branch information
jvalkeal committed Feb 1, 2017
1 parent 0c0ba9a commit f10db78
Showing 1 changed file with 5 additions and 5 deletions.
Expand Up @@ -137,16 +137,16 @@ protected void deployModules(Container container) throws Exception {
try {
stream = DeploymentLoader.loadStream(client, unitName, streamFactory);
streamMap.put(unitName, stream);
if (stream != null) {
streamModuleDeployments.add(new ModuleDeployment(stream,
stream.getModuleDescriptor(moduleDeploymentsPath.getModuleLabel()),
deploymentProperties));
}
}
catch (Exception e) {
logger.error(String.format("Exception loading stream %s.", unitName), e);
}
}
if (stream != null) {
streamModuleDeployments.add(new ModuleDeployment(stream,
stream.getModuleDescriptor(moduleDeploymentsPath.getModuleLabel()),
deploymentProperties));
}
}
}

Expand Down

0 comments on commit f10db78

Please sign in to comment.