org.springframework.xd.dirt.server

Class StreamDeploymentListener

java.lang.Object

org.springframework.xd.dirt.server.InitialDeploymentListener

org.springframework.xd.dirt.server.StreamDeploymentListener

All Implemented Interfaces:

org.apache.curator.framework.recipes.cache.PathChildrenCacheListener

public class StreamDeploymentListener
extends InitialDeploymentListener

Listener implementation that handles stream deployment requests.

Author:

Patrick Peralta, Mark Fisher, Ilayaperumal Gopinathan

Field Summary

Fields inherited from class org.springframework.xd.dirt.server.InitialDeploymentListener

containerMatcher, containerRepository, moduleDeploymentWriter, stateCalculator

Constructor Summary

Constructors

Constructor and Description
StreamDeploymentListener(ZooKeeperConnection zkConnection, org.apache.curator.framework.recipes.cache.PathChildrenCache moduleDeploymentRequests, ContainerRepository containerRepository, StreamFactory streamFactory, ContainerMatcher containerMatcher, DeploymentUnitStateCalculator stateCalculator) Construct a StreamDeploymentListener.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	onChildAdded(org.apache.curator.framework.CuratorFramework client, org.apache.curator.framework.recipes.cache.ChildData data) Handle the creation of a new stream deployment.
void	recalculateStreamStates(org.apache.curator.framework.CuratorFramework client, org.apache.curator.framework.recipes.cache.PathChildrenCache streamDeployments) Iterate all deployed streams, recalculate the state of each, and create an ephemeral node indicating the stream state.

Methods inherited from class org.springframework.xd.dirt.server.InitialDeploymentListener

childEvent, createModuleDeploymentRequestsPath, onChildRemoved

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamDeploymentListener

public StreamDeploymentListener(ZooKeeperConnection zkConnection,
                        org.apache.curator.framework.recipes.cache.PathChildrenCache moduleDeploymentRequests,
                        ContainerRepository containerRepository,
                        StreamFactory streamFactory,
                        ContainerMatcher containerMatcher,
                        DeploymentUnitStateCalculator stateCalculator)

Construct a StreamDeploymentListener.

Parameters:

zkConnection - ZooKeeper connection

moduleDeploymentRequests - the requested deployment modules

containerRepository - repository to obtain container data

streamFactory - factory to construct Stream

containerMatcher - matches modules to containers

stateCalculator - calculator for stream state

Method Detail

onChildAdded

protected void onChildAdded(org.apache.curator.framework.CuratorFramework client,
                org.apache.curator.framework.recipes.cache.ChildData data)
                     throws java.lang.Exception

Handle the creation of a new stream deployment.

Specified by:

onChildAdded in class InitialDeploymentListener

Parameters:

client - curator client

data - stream deployment request data

Throws:

java.lang.Exception

recalculateStreamStates

public void recalculateStreamStates(org.apache.curator.framework.CuratorFramework client,
                           org.apache.curator.framework.recipes.cache.PathChildrenCache streamDeployments)
                             throws java.lang.Exception

Iterate all deployed streams, recalculate the state of each, and create an ephemeral node indicating the stream state. This is typically invoked upon leader election.

Parameters:

client - curator client

streamDeployments - curator cache of stream deployments

Throws:

java.lang.Exception