org.springframework.xd.dirt.stream

Class StreamDeployer

java.lang.Object

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

org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer<StreamDefinition,Stream>

org.springframework.xd.dirt.stream.StreamDeployer

All Implemented Interfaces:

ResourceDeployer<StreamDefinition>

public class StreamDeployer
extends AbstractInstancePersistingDeployer<StreamDefinition,Stream>

Default implementation of StreamDeployer that emits deployment request messages on a bus and relies on StreamDefinitionRepository and StreamRepository for persistence.

Author:

Mark Fisher, Gary Russell, Andy Clement, Eric Bottard, Gunnar Hillert

Field Summary

Fields inherited from class org.springframework.xd.dirt.stream.AbstractDeployer

definitionKind

Constructor Summary

Constructors

Constructor and Description
StreamDeployer(StreamDefinitionRepository repository, DeploymentMessageSender messageSender, StreamRepository streamRepository, XDParser parser)

Method Summary

Methods

Modifier and Type	Method and Description
protected Stream	makeInstance(StreamDefinition definition) Create an running instance out of the given definition;

Methods inherited from class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer

delete, deleteAll, deploy, deployAll, deploymentInfo, undeploy, undeployAll

Methods inherited from class org.springframework.xd.dirt.stream.AbstractDeployer

basicDeploy, basicUndeploy, findAll, findAll, findOne, getDefinitionRepository, parse, save, sendDeploymentRequests, throwAlreadyDeployedException, throwDefinitionAlreadyExistsException, throwNoSuchDefinitionException, throwNoSuchDefinitionException, throwNotDeployedException

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamDeployer

public StreamDeployer(StreamDefinitionRepository repository,
              DeploymentMessageSender messageSender,
              StreamRepository streamRepository,
              XDParser parser)

Method Detail

makeInstance

protected Stream makeInstance(StreamDefinition definition)

Description copied from class: AbstractInstancePersistingDeployer

Create an running instance out of the given definition;

Specified by:

makeInstance in class AbstractInstancePersistingDeployer<StreamDefinition,Stream>