@Override
		public void run() {
			try {
				CuratorFramework client = zkConnection.getClient();
				Set<String> containerDeployments = new HashSet<String>();

				try {
					containerDeployments.addAll(client.getChildren().forPath(
							Paths.build(Paths.MODULE_DEPLOYMENTS, Paths.ALLOCATED)));
					containerDeployments.removeAll(client.getChildren().forPath(Paths.build(Paths.CONTAINERS)));
				}
				catch (KeeperException.NoNodeException e) {
					// ignore
				}

				for (String containerName : containerDeployments) {
					Container container = new Container(containerName, Collections.<String, String> emptyMap());
					departedContainerModuleRedeployer.deployModules(container);
				}
			}
			catch (Exception e) {
				logger.error("Exception while handling departed containers", e);
			}
		}
Schedule immediate execution of this runnable.
spring-xd-dirt/src/main/java/org/springframework/xd/dirt/server/admin/deployment/zk/ContainerListener.java