public class JobDeployer extends AbstractInstancePersistingDeployer<JobDefinition,Job> implements org.springframework.beans.factory.DisposableBean
instanceRepositorydefinitionKind, parser| Constructor and Description |
|---|
JobDeployer(ZooKeeperConnection zkConnection,
JobDefinitionRepository definitionRepository,
JobRepository instanceRepository,
XDParser parser,
MessageBus messageBus) |
| Modifier and Type | Method and Description |
|---|---|
protected JobDefinition |
createDefinition(java.lang.String name,
java.lang.String definition) |
void |
destroy() |
protected java.lang.String |
getDeploymentPath(JobDefinition definition)
Return the ZooKeeper path used for deployment requests for the
given definition.
|
void |
launch(java.lang.String name,
java.lang.String jobParameters) |
protected Job |
makeInstance(JobDefinition definition)
Create an running instance out of the given definition;
|
beforeDelete, deleteAll, deploy, deploymentInfo, deploymentInfo, undeploy, undeployAllafterSave, basicDeploy, delete, findAll, findAll, findOne, getDefinitionRepository, getZooKeeperConnection, save, throwAlreadyDeployedException, throwDefinitionAlreadyExistsException, throwDefinitionNotDeployable, throwNoSuchDefinitionException, throwNoSuchDefinitionException, throwNotDeployedExceptionpublic JobDeployer(ZooKeeperConnection zkConnection, JobDefinitionRepository definitionRepository, JobRepository instanceRepository, XDParser parser, MessageBus messageBus)
protected Job makeInstance(JobDefinition definition)
AbstractInstancePersistingDeployermakeInstance in class AbstractInstancePersistingDeployer<JobDefinition,Job>public void launch(java.lang.String name,
java.lang.String jobParameters)
protected JobDefinition createDefinition(java.lang.String name, java.lang.String definition)
createDefinition in class AbstractDeployer<JobDefinition>protected java.lang.String getDeploymentPath(JobDefinition definition)
AbstractDeployergetDeploymentPath in class AbstractDeployer<JobDefinition>definition - definition for which to obtain pathpublic void destroy()
throws java.lang.Exception
destroy in interface org.springframework.beans.factory.DisposableBeanjava.lang.Exception