org.springframework.xd.dirt.server

Class DeploymentLoader

java.lang.Object

org.springframework.xd.dirt.server.DeploymentLoader

public class DeploymentLoader
extends java.lang.Object

Utility for loading streams and jobs for the purpose of deployment.

Implementation note: this should eventually be merged/replaced with ZooKeeperStreamRepository and ZooKeeperJobRepository.

Author:

Patrick Peralta, Ilayaperumal Gopinathan

See Also:

ContainerListener, JobDeploymentListener, StreamDeploymentListener

Constructor Summary

Constructors

Constructor and Description
DeploymentLoader()

Method Summary

Methods

Modifier and Type	Method and Description
static Job	loadJob(org.apache.curator.framework.CuratorFramework client, java.lang.String jobName, JobFactory jobFactory) Load the Job instance for a given job nameif the job is deployed.
static Stream	loadStream(org.apache.curator.framework.CuratorFramework client, java.lang.String streamName, StreamFactory streamFactory) Load the Stream instance for a given stream name if the stream is deployed.

Methods inherited from class java.lang.Object

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

Constructor Detail

DeploymentLoader

public DeploymentLoader()

Method Detail

loadJob

public static Job loadJob(org.apache.curator.framework.CuratorFramework client,
          java.lang.String jobName,
          JobFactory jobFactory)
                   throws java.lang.Exception

Load the Job instance for a given job nameif the job is deployed.

Parameters:

client - curator client

jobName - the name of the job to load

jobFactory - job factory used to create instance of job

Returns:

the job instance, or null if the job does not exist or is not deployed

Throws:

java.lang.Exception

loadStream

public static Stream loadStream(org.apache.curator.framework.CuratorFramework client,
                java.lang.String streamName,
                StreamFactory streamFactory)
                         throws java.lang.Exception

Load the Stream instance for a given stream name if the stream is deployed. It will include the stream definition as well as any deployment properties data for the stream deployment.

Parameters:

client - curator client

streamName - the name of the stream to load

streamFactory - stream factory used to create instance of stream

Returns:

the stream instance, or null if the stream does not exist or is not deployed

Throws:

java.lang.Exception - if ZooKeeper access fails for any reason