org.springframework.xd.dirt.server.admin.deployment.zk

Class ZKStreamDeploymentHandler

java.lang.Object

org.springframework.xd.dirt.server.admin.deployment.zk.ZKDeploymentHandler

org.springframework.xd.dirt.server.admin.deployment.zk.ZKStreamDeploymentHandler

All Implemented Interfaces:

DeploymentHandler, SupervisorElectionListener

public class ZKStreamDeploymentHandler
extends ZKDeploymentHandler

Deployment handler that is responsible for deploying Stream.

Author:

Patrick Peralta, Mark Fisher, Ilayaperumal Gopinathan

Field Summary

Fields inherited from class org.springframework.xd.dirt.server.admin.deployment.zk.ZKDeploymentHandler

moduleDeploymentRequests, zkConnection

Constructor Summary

Constructors

Constructor and Description
ZKStreamDeploymentHandler()

Method Summary

Methods

Modifier and Type	Method and Description
void	deploy(java.lang.String streamName) Deploy the stream with the given name.

Methods inherited from class org.springframework.xd.dirt.server.admin.deployment.zk.ZKDeploymentHandler

createModuleDeploymentRequestsPath, onSupervisorElected, undeploy

Methods inherited from class java.lang.Object

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

Constructor Detail

ZKStreamDeploymentHandler

public ZKStreamDeploymentHandler()

Method Detail

deploy

public void deploy(java.lang.String streamName)
            throws java.lang.Exception

Deploy the stream with the given name.

Parameters:

streamName - the stream name

Throws:

java.lang.Exception