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.context.ApplicationContextAware, org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>

public class ContainerRegistrar
extends java.lang.Object
implements org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>, org.springframework.context.ApplicationContextAware

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

Constructor Summary

Constructors

Constructor and Description
ContainerRegistrar(ZooKeeperConnection zkConnection, ContainerAttributes containerAttributes, ContainerRepository containerRepository, org.springframework.xd.dirt.server.DeploymentListener deploymentListener) 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.ApplicationEvent event)
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

ContainerRegistrar

public ContainerRegistrar(ZooKeeperConnection zkConnection,
                  ContainerAttributes containerAttributes,
                  ContainerRepository containerRepository,
                  org.springframework.xd.dirt.server.DeploymentListener deploymentListener)

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

zkConnection - ZooKeeper connection

Method Detail

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.ApplicationEvent event)

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>