public class StreamDeployer extends AbstractInstancePersistingDeployer<StreamDefinition,Stream>
StreamDeployer that emits deployment request messages on a bus and relies on
StreamDefinitionRepository and StreamRepository for persistence.definitionKind| Constructor and Description |
|---|
StreamDeployer(StreamDefinitionRepository repository,
DeploymentMessageSender messageSender,
StreamRepository streamRepository,
XDParser parser) |
| Modifier and Type | Method and Description |
|---|---|
protected Stream |
makeInstance(StreamDefinition definition)
Create an running instance out of the given definition;
|
delete, deleteAll, deploy, deployAll, deploymentInfo, undeploy, undeployAllbasicDeploy, basicUndeploy, findAll, findAll, findOne, getDefinitionRepository, parse, save, sendDeploymentRequests, throwAlreadyDeployedException, throwDefinitionAlreadyExistsException, throwNoSuchDefinitionException, throwNoSuchDefinitionException, throwNotDeployedExceptionpublic StreamDeployer(StreamDefinitionRepository repository, DeploymentMessageSender messageSender, StreamRepository streamRepository, XDParser parser)
protected Stream makeInstance(StreamDefinition definition)
AbstractInstancePersistingDeployermakeInstance in class AbstractInstancePersistingDeployer<StreamDefinition,Stream>