org.springframework.xd.dirt.test

Class SingleNodeIntegrationTestSupport

java.lang.Object

org.springframework.xd.dirt.test.SingleNodeIntegrationTestSupport

public class SingleNodeIntegrationTestSupport
extends java.lang.Object

A helper class that provides methods used for testing streams with SingleNodeApplication. It exposes components and methods used for stream creation, deployment, and destruction and provides access to the MessageBus. Additionally, it supports registration of modules contained in a local resource location (default: "file:./config").

Author:

David Turanski, Ilayaperumal Gopinathan

Constructor Summary

Constructors

Constructor and Description
SingleNodeIntegrationTestSupport(SingleNodeApplication application)
SingleNodeIntegrationTestSupport(SingleNodeApplication application, java.lang.String moduleResourceLocation) Constructor useful for testing custom modules

Method Summary

Methods

Modifier and Type	Method and Description
void	addPathListener(java.lang.String path, org.apache.curator.framework.recipes.cache.PathChildrenCacheListener listener) Add a PathChildrenCacheListener for the given path.
boolean	createAndDeployStream(StreamDefinition definition)
void	deleteStream(java.lang.String name)
boolean	deployStream(StreamDefinition definition)
boolean	deployStream(StreamDefinition definition, java.util.Map<java.lang.String,java.lang.String> properties)
java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,Module>>	getDeployedModules()
Module	getModule(java.lang.String streamName, java.lang.String moduleName, int index)
DeploymentVerifier	jobDeploymentVerifier()
MessageBusSupport	messageBus()
void	removePathListener(java.lang.String path, org.apache.curator.framework.recipes.cache.PathChildrenCacheListener listener) Remove a PathChildrenCacheListener for the given path.
StreamDefinitionRepository	streamDefinitionRepository()
StreamDeployer	streamDeployer()
DeploymentVerifier	streamDeploymentVerifier()
StreamRepository	streamRepository()
boolean	undeployAndDestroyStream(StreamDefinition definition)
boolean	undeployStream(StreamDefinition definition)
ZooKeeperConnection	zooKeeperConnection()

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleNodeIntegrationTestSupport

public SingleNodeIntegrationTestSupport(SingleNodeApplication application)

SingleNodeIntegrationTestSupport

public SingleNodeIntegrationTestSupport(SingleNodeApplication application,
                                java.lang.String moduleResourceLocation)

Constructor useful for testing custom modules

Parameters:

application - the SingleNodeApplication

moduleResourceLocation - an additional Spring (file: or classpath:) resource location used by the ModuleRegistry

Method Detail

getDeployedModules

public final java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,Module>> getDeployedModules()

streamDeploymentVerifier

public final DeploymentVerifier streamDeploymentVerifier()

jobDeploymentVerifier

public final DeploymentVerifier jobDeploymentVerifier()

streamDeployer

public final StreamDeployer streamDeployer()

streamRepository

public final StreamRepository streamRepository()

streamDefinitionRepository

public final StreamDefinitionRepository streamDefinitionRepository()

messageBus

public final MessageBusSupport messageBus()

deployStream

public final boolean deployStream(StreamDefinition definition)

deployStream

public final boolean deployStream(StreamDefinition definition,
                   java.util.Map<java.lang.String,java.lang.String> properties)

createAndDeployStream

public final boolean createAndDeployStream(StreamDefinition definition)

undeployStream

public final boolean undeployStream(StreamDefinition definition)

undeployAndDestroyStream

public final boolean undeployAndDestroyStream(StreamDefinition definition)

deleteStream

public final void deleteStream(java.lang.String name)

getModule

public final Module getModule(java.lang.String streamName,
               java.lang.String moduleName,
               int index)

zooKeeperConnection

public ZooKeeperConnection zooKeeperConnection()

addPathListener

public void addPathListener(java.lang.String path,
                   org.apache.curator.framework.recipes.cache.PathChildrenCacheListener listener)

Add a PathChildrenCacheListener for the given path.

Parameters:

path - the path whose children to listen to

listener - the children listener

removePathListener

public void removePathListener(java.lang.String path,
                      org.apache.curator.framework.recipes.cache.PathChildrenCacheListener listener)

Remove a PathChildrenCacheListener for the given path.

Parameters:

path - the path whose children to listen to

listener - the children listener