org.springframework.xd.dirt.stream

Class AbstractDeployer<D extends BaseDefinition>

java.lang.Object

org.springframework.xd.dirt.stream.AbstractDeployer<D>

All Implemented Interfaces:

ResourceDeployer<D>

Direct Known Subclasses:

JobDeployer, StreamDeployer, TapDeployer, TriggerDeployer

public abstract class AbstractDeployer<D extends BaseDefinition>
extends java.lang.Object
implements ResourceDeployer<D>

Abstract implementation of the @link ResourceDeployer interface. It provides the basic support for calling CrudRepository methods and sending deployment messages.

Author:

Luke Taylor, Mark Pollack, Eric Bottard, Andy Clement

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AbstractDeployer.ErrorMessage

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractDeployer(org.springframework.data.repository.PagingAndSortingRepository<D,java.lang.String> repository, DeploymentMessageSender messageSender, XDParser parser, java.lang.String definitionKind)

Method Summary

Methods

Modifier and Type	Method and Description
void	deploy(java.lang.String name)
java.lang.Iterable<D>	findAll() Return all definitions ordered by BaseDefinition.getName() ascending.
org.springframework.data.domain.Page<D>	findAll(org.springframework.data.domain.Pageable pageable)
D	findOne(java.lang.String name) Retrieves a single Definition or null if none is found.
protected org.springframework.data.repository.CrudRepository<D,java.lang.String>	getRepository()
protected java.util.List<ModuleDeploymentRequest>	parse(java.lang.String name, java.lang.String config)
void	remove(java.lang.String name)
D	save(D definition)
protected void	sendDeploymentRequests(java.lang.String name, java.util.List<ModuleDeploymentRequest> requests)
protected void	throwAlreadyDeployedException(java.lang.String name)
protected void	throwDefinitionAlreadyExistsException(D definition)
protected void	throwNoSuchDefinitionException(java.lang.String name)
void	undeploy(java.lang.String name)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.xd.dirt.core.ResourceDeployer

delete

Constructor Detail

AbstractDeployer

protected AbstractDeployer(org.springframework.data.repository.PagingAndSortingRepository<D,java.lang.String> repository,
                DeploymentMessageSender messageSender,
                XDParser parser,
                java.lang.String definitionKind)

Method Detail

save

public D save(D definition)

Specified by:

save in interface ResourceDeployer<D extends BaseDefinition>

throwDefinitionAlreadyExistsException

protected void throwDefinitionAlreadyExistsException(D definition)

throwNoSuchDefinitionException

protected void throwNoSuchDefinitionException(java.lang.String name)

throwAlreadyDeployedException

protected void throwAlreadyDeployedException(java.lang.String name)

deploy

public void deploy(java.lang.String name)

Specified by:

deploy in interface ResourceDeployer<D extends BaseDefinition>

findOne

public D findOne(java.lang.String name)

Description copied from interface: ResourceDeployer

Retrieves a single Definition or null if none is found.

Specified by:

findOne in interface ResourceDeployer<D extends BaseDefinition>

Parameters:

name - of the definition to find. Must not be null.

findAll

public java.lang.Iterable<D> findAll()

Description copied from interface: ResourceDeployer

Return all definitions ordered by BaseDefinition.getName() ascending.

Specified by:

findAll in interface ResourceDeployer<D extends BaseDefinition>

findAll

public org.springframework.data.domain.Page<D> findAll(org.springframework.data.domain.Pageable pageable)

getRepository

protected org.springframework.data.repository.CrudRepository<D,java.lang.String> getRepository()

sendDeploymentRequests

protected void sendDeploymentRequests(java.lang.String name,
                          java.util.List<ModuleDeploymentRequest> requests)

parse

protected java.util.List<ModuleDeploymentRequest> parse(java.lang.String name,
                                            java.lang.String config)

undeploy

public void undeploy(java.lang.String name)

Specified by:

undeploy in interface ResourceDeployer<D extends BaseDefinition>

remove

public void remove(java.lang.String name)