Examples of org.springframework.xd.dirt.core.ModuleDeploymentsPath

Package org.springframework.xd.dirt.core

Examples of org.springframework.xd.dirt.core.ModuleDeploymentsPath

org.springframework.xd.dirt.core.ModuleDeploymentsPath
Builder object for paths under {@link Paths#DEPLOYMENTS} for module deployments. {@code ModuleDeploymentsPath}can be used to take a full path and split it into its elements, for example:
ModuleDeploymentsPath deploymentsPath = new ModuleDeploymentsPath("/xd/deployments/modules/4dbd28e2-880d-4774/my-stream.source.http-0"); assertEquals("my-stream", deploymentsPath.getStreamName());
It can also be used to build a path, for example:
ModuleDeploymentsPath deploymentsPath = new ModuleDeploymentsPath().setStreamName("my-stream").setContainer(...)...; assertEquals("/xd/deployments/modules/4dbd28e2-880d-4774/my-stream.source.http-0", deploymentsPath.build());
@author Patrick Peralta @author Ilayaperumal Gopinathan

   *
   * @return path for this status
   * @see #toMap
   */
  public String buildPath() {
    return Paths.build(new ModuleDeploymentsPath()
        .setContainer(container)
        .setDeploymentUnitName(key.getGroup())
        .setModuleType(key.getType().toString())
        .setModuleLabel(key.getLabel())
        .setModuleSequence(String.valueOf(moduleSequence)).build(), Paths.STATUS);

View Full Code Here

     * {@inheritDoc}
     */
    @Override
    public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) throws Exception {
      ZooKeeperUtils.logCacheEvent(logger, event);
      ModuleDeploymentsPath path = new ModuleDeploymentsPath(event.getData().getPath());
      if (event.getType().equals(Type.CHILD_ADDED)) {
        deployQueues.putIfAbsent(path.getDeploymentUnitName(),
            new LinkedBlockingQueue<PathChildrenCacheEvent>());
        LinkedBlockingQueue<PathChildrenCacheEvent> queue = deployQueues.get(path.getDeploymentUnitName());
        queue.put(event);
      }
      else if (event.getType().equals(Type.CHILD_REMOVED)) {
        undeployQueues.putIfAbsent(path.getDeploymentUnitName(),
            new LinkedBlockingQueue<PathChildrenCacheEvent>());
        LinkedBlockingQueue<PathChildrenCacheEvent> queue = undeployQueues.get(path.getDeploymentUnitName());
        queue.put(event);
      }
    }

View Full Code Here

0 1

TOP

Related Classes of org.springframework.xd.dirt.core.ModuleDeploymentsPath

org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository

org.springframework.xd.dirt.server.DepartingContainerModuleRedeployer

org.springframework.xd.dirt.server.DeploymentListener

org.springframework.xd.dirt.server.DeploymentListener$JobModuleWatcher

org.springframework.xd.dirt.server.DeploymentListener$StreamModuleWatcher

org.springframework.xd.dirt.server.ModuleDeploymentStatus

org.springframework.xd.dirt.server.ModuleDeploymentWriter

org.springframework.xd.dirt.stream.AbstractSingleNodeStreamDeploymentIntegrationTests$DeploymentsListener

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.