org.springframework.xd.dirt.server

Class ContainerRegistrar

java.lang.Object

org.springframework.xd.dirt.server.ContainerRegistrar

All Implemented Interfaces:

java.util.EventListener, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>

public class ContainerRegistrar
extends java.lang.Object
implements org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>, org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.BeanClassLoaderAware

An instance of this class, registered as a bean in the context for a Container, will handle the registration of that Container's metadata with ZooKeeper by creating an ephemeral node. If the ZooKeeperConnection used by this registrar is closed, that ephemeral node will be eagerly deleted. Since the ZooKeeperConnection typically has its lifecycle managed by Spring, that would be the normal behavior when the owning ApplicationContext is itself closed.

Author:

Mark Fisher, David Turanski, Ilayaperumal Gopinathan

Field Summary

Fields

Modifier and Type	Field and Description
protected DeploymentLoader	deploymentLoader Utility for loading streams and jobs (including deployment metadata).

Constructor Summary

Constructors

Constructor and Description

ContainerRegistrar(ZooKeeperConnection zkConnection, ContainerAttributes containerAttributes, ContainerRepository containerRepository, StreamFactory streamFactory, JobFactory jobFactory, ModuleOptionsMetadataResolver moduleOptionsMetadataResolver, ModuleDeployer moduleDeployer) Create an instance that will register the provided ContainerAttributes whenever the underlying ZooKeeperConnection is established.

Method Summary

Methods

Modifier and Type	Method and Description
void	onApplicationEvent(org.springframework.context.event.ContextRefreshedEvent event)
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
void	setBeanClassLoader(java.lang.ClassLoader classLoader)
protected void	undeployModule(java.lang.String streamName, java.lang.String moduleType, java.lang.String moduleLabel) Undeploy the requested module.

Methods inherited from class java.lang.Object

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

Field Detail

deploymentLoader

protected final DeploymentLoader deploymentLoader

Utility for loading streams and jobs (including deployment metadata).

Constructor Detail

ContainerRegistrar

public ContainerRegistrar(ZooKeeperConnection zkConnection,
                  ContainerAttributes containerAttributes,
                  ContainerRepository containerRepository,
                  StreamFactory streamFactory,
                  JobFactory jobFactory,
                  ModuleOptionsMetadataResolver moduleOptionsMetadataResolver,
                  ModuleDeployer moduleDeployer)

Create an instance that will register the provided ContainerAttributes whenever the underlying ZooKeeperConnection is established. If that connection is already established at the time this instance receives a ContextRefreshedEvent, the attributes will be registered then. Otherwise, registration occurs within a callback that is invoked for connected events as well as reconnected events.

Parameters:

containerAttributes - runtime and configured attributes for the container

containerRepository - repository for the containers

streamFactory - factory to construct Stream

jobFactory - factory to construct Job

moduleOptionsMetadataResolver - resolver for module options metadata

moduleDeployer - module deployer

zkConnection - ZooKeeper connection

Method Detail

undeployModule

protected void undeployModule(java.lang.String streamName,
                  java.lang.String moduleType,
                  java.lang.String moduleLabel)

Undeploy the requested module.

Parameters:

streamName - name of the stream for the module

moduleType - module type

moduleLabel - module label

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

onApplicationEvent

public void onApplicationEvent(org.springframework.context.event.ContextRefreshedEvent event)

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>

setBeanClassLoader

public void setBeanClassLoader(java.lang.ClassLoader classLoader)

Specified by:

setBeanClassLoader in interface org.springframework.beans.factory.BeanClassLoaderAware