org.springframework.xd.dirt.server

Class ContainerListener

java.lang.Object

org.springframework.xd.dirt.server.ContainerListener

All Implemented Interfaces:

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

public class ContainerListener
extends java.lang.Object
implements org.apache.curator.framework.recipes.cache.PathChildrenCacheListener

Listener implementation that is invoked when containers are added/removed/modified.

Author:

Patrick Peralta, Mark Fisher, Ilayaperumal Gopinathan

Constructor Summary

Constructors

Constructor and Description

ContainerListener(ZooKeeperConnection zkConnection, ContainerRepository containerRepository, StreamFactory streamFactory, JobFactory jobFactory, org.apache.curator.framework.recipes.cache.PathChildrenCache streamDeployments, org.apache.curator.framework.recipes.cache.PathChildrenCache jobDeployments, org.apache.curator.framework.recipes.cache.PathChildrenCache moduleDeploymentRequests, ContainerMatcher containerMatcher, DeploymentUnitStateCalculator stateCalculator) Construct a ContainerListener.

Method Summary

Methods

Modifier and Type	Method and Description
void	childEvent(org.apache.curator.framework.CuratorFramework client, org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent event)

Methods inherited from class java.lang.Object

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

Constructor Detail

ContainerListener

public ContainerListener(ZooKeeperConnection zkConnection,
                 ContainerRepository containerRepository,
                 StreamFactory streamFactory,
                 JobFactory jobFactory,
                 org.apache.curator.framework.recipes.cache.PathChildrenCache streamDeployments,
                 org.apache.curator.framework.recipes.cache.PathChildrenCache jobDeployments,
                 org.apache.curator.framework.recipes.cache.PathChildrenCache moduleDeploymentRequests,
                 ContainerMatcher containerMatcher,
                 DeploymentUnitStateCalculator stateCalculator)

Construct a ContainerListener.

Parameters:

zkConnection - ZooKeeper connection

streamFactory - factory to construct Stream

jobFactory - factory to construct Job

streamDeployments - cache of children for stream deployments path

jobDeployments - cache of children for job deployments path

moduleDeploymentRequests - cache of children for requested module deployments path

containerMatcher - matches modules to containers

stateCalculator - calculator for stream/job state

Method Detail

childEvent

public void childEvent(org.apache.curator.framework.CuratorFramework client,
              org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent event)
                throws java.lang.Exception

Specified by:

childEvent in interface org.apache.curator.framework.recipes.cache.PathChildrenCacheListener

Throws:

java.lang.Exception