org.springframework.xd.dirt.stream

Class DefaultStreamDeployer

java.lang.Object

org.springframework.xd.dirt.stream.DefaultStreamDeployer

All Implemented Interfaces:

StreamDeployer

public class DefaultStreamDeployer
extends java.lang.Object
implements StreamDeployer

Author:

Mark Fisher, Gary Russell, Andy Clement

Constructor Summary

Constructors

Constructor and Description
DefaultStreamDeployer(org.springframework.integration.MessageChannel outputChannel)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	addDeployment(java.lang.String name, java.util.List<ModuleDeploymentRequest> modules)
void	deployStream(java.lang.String name, java.lang.String config)
protected java.util.List<ModuleDeploymentRequest>	removeDeployment(java.lang.String name)
void	undeployStream(java.lang.String name)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultStreamDeployer

public DefaultStreamDeployer(org.springframework.integration.MessageChannel outputChannel)

Method Detail

deployStream

public void deployStream(java.lang.String name,
                java.lang.String config)

Specified by:

deployStream in interface StreamDeployer

undeployStream

public void undeployStream(java.lang.String name)

Specified by:

undeployStream in interface StreamDeployer

addDeployment

protected final void addDeployment(java.lang.String name,
                 java.util.List<ModuleDeploymentRequest> modules)

removeDeployment

protected java.util.List<ModuleDeploymentRequest> removeDeployment(java.lang.String name)