org.springframework.xd.dirt.server

Class DepartingContainerModuleRedeployer

java.lang.Object

org.springframework.xd.dirt.server.ModuleRedeployer

org.springframework.xd.dirt.server.DepartingContainerModuleRedeployer

public class DepartingContainerModuleRedeployer
extends ModuleRedeployer

The ModuleRedeployer that re-deploys the stream/job modules that were deployed into the departing container.

Author:

Patrick Peralta, Mark Fisher, Ilayaperumal Gopinathan

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.xd.dirt.server.ModuleRedeployer

ModuleRedeployer.ModuleDeployment

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	logger Logger.

Fields inherited from class org.springframework.xd.dirt.server.ModuleRedeployer

jobFactory, moduleDeploymentRequests, streamFactory

Constructor Summary

Constructors

Constructor and Description
DepartingContainerModuleRedeployer(ZooKeeperConnection zkConnection, ContainerRepository containerRepository, StreamFactory streamFactory, JobFactory jobFactory, org.apache.curator.framework.recipes.cache.PathChildrenCache moduleDeploymentRequests, ContainerMatcher containerMatcher, DeploymentUnitStateCalculator stateCalculator) Constructs DepartingContainerModuleRedeployer

Method Summary

Methods

Modifier and Type	Method and Description
protected void	deployModules(Container container) Handle the departure of a container.

Methods inherited from class org.springframework.xd.dirt.server.ModuleRedeployer

getAllModuleDeploymentRequests, getClient, instantiateContainerMatcher, logUnwantedRedeployment, redeployModule, updateDeploymentUnitState

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

protected final org.slf4j.Logger logger

Logger.

Constructor Detail

DepartingContainerModuleRedeployer

public DepartingContainerModuleRedeployer(ZooKeeperConnection zkConnection,
                                  ContainerRepository containerRepository,
                                  StreamFactory streamFactory,
                                  JobFactory jobFactory,
                                  org.apache.curator.framework.recipes.cache.PathChildrenCache moduleDeploymentRequests,
                                  ContainerMatcher containerMatcher,
                                  DeploymentUnitStateCalculator stateCalculator)

Constructs DepartingContainerModuleRedeployer

Parameters:

zkConnection - ZooKeeper connection

containerRepository - the repository to find the containers

streamFactory - factory to construct Stream

jobFactory - factory to construct Job

moduleDeploymentRequests - cache of children for requested module deployments path

containerMatcher - matches modules to containers

stateCalculator - calculator for stream/job state

Method Detail

deployModules

protected void deployModules(Container container)
                      throws java.lang.Exception

Handle the departure of a container. This will scan the list of modules deployed to the departing container and redeploy them if required.

Specified by:

deployModules in class ModuleRedeployer

Parameters:

container - the container that departed

Throws:

java.lang.Exception