org.springframework.xd.dirt.test

Class DeploymentVerifier

java.lang.Object

org.springframework.xd.dirt.test.DeploymentVerifier

public class DeploymentVerifier
extends java.lang.Object

Verifies deployments or undeployments via inspection of ZooKeeper paths. Each of the wait... methods block for a specified amount of time and throw RuntimeTimeoutException if the expected path is not present (in the case of create/deploy) or is still present (in the case of undeploy/destroy) in the time allotted. Deployment paths are determined by the DeploymentPathProvider passed into the constructor.

Author:

Patrick Peralta, Ilayaperumal Gopinathan

Constructor Summary

Constructors

Constructor and Description
DeploymentVerifier(ZooKeeperConnection zkConnection, DeploymentPathProvider provider) Construct a DeploymentVerifier using the default timeout indicated by DEFAULT_TIMEOUT.
DeploymentVerifier(ZooKeeperConnection zkConnection, DeploymentPathProvider provider, int verifyTimeout) Construct a DeploymentVerifier using the provided timeout.

Method Summary

Methods

Modifier and Type	Method and Description
protected ZooKeeperConnection	getZooKeeperConnection() Return the ZooKeeper connection.
void	waitForCreate(java.lang.String name) Block the executing thread until the named deployment definition has been created.
void	waitForDeploy(java.lang.String name) Block the executing thread until the named deployment has been deployed.
void	waitForDestroy(java.lang.String name) Block the executing thread until the named deployment definition has been destroyed.
void	waitForUndeploy(java.lang.String name) Block the executing thread until the named deployment has been undeployed.

Methods inherited from class java.lang.Object

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

Constructor Detail

DeploymentVerifier

public DeploymentVerifier(ZooKeeperConnection zkConnection,
                  DeploymentPathProvider provider)

Construct a DeploymentVerifier using the default timeout indicated by DEFAULT_TIMEOUT.

Parameters:

zkConnection - ZooKeeper connection

provider - definition/deployment path provider

DeploymentVerifier

public DeploymentVerifier(ZooKeeperConnection zkConnection,
                  DeploymentPathProvider provider,
                  int verifyTimeout)

Construct a DeploymentVerifier using the provided timeout.

Parameters:

zkConnection - ZooKeeper connection

provider - definition/deployment path provider

verifyTimeout - timeout value in milliseconds

Method Detail

getZooKeeperConnection

protected ZooKeeperConnection getZooKeeperConnection()

Return the ZooKeeper connection.

Returns:

the ZooKeeper connection

waitForCreate

public void waitForCreate(java.lang.String name)
                   throws RuntimeTimeoutException

Block the executing thread until the named deployment definition has been created.

Parameters:

name - deployment name

Throws:

RuntimeTimeoutException - if the definition isn't created in the allotted time

waitForDestroy

public void waitForDestroy(java.lang.String name)
                    throws RuntimeTimeoutException

Block the executing thread until the named deployment definition has been destroyed.

Parameters:

name - deployment name

Throws:

RuntimeTimeoutException - if the definition isn't destroyed in the allotted time

waitForDeploy

public void waitForDeploy(java.lang.String name)
                   throws RuntimeTimeoutException

Block the executing thread until the named deployment has been deployed.

Parameters:

name - deployment name

Throws:

RuntimeTimeoutException - if the deployment isn't deployed in the allotted time

waitForUndeploy

public void waitForUndeploy(java.lang.String name)
                     throws RuntimeTimeoutException

Block the executing thread until the named deployment has been undeployed.

Parameters:

name - deployment name

Throws:

RuntimeTimeoutException - if the deployment isn't undeployed in the allotted time