org.springframework.xd.dirt.test.process

Class SingleNodeProcessingChainSupport

java.lang.Object

org.springframework.xd.dirt.test.process.SingleNodeProcessingChainSupport

public final class SingleNodeProcessingChainSupport
extends java.lang.Object

A helper class to easily create AbstractSingleNodeProcessingChains using static methods.

Author:

David Turanski

Method Summary

Methods

Modifier and Type	Method and Description
static SingleNodeProcessingChain	chain(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain)
static SingleNodeProcessingChain	chain(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain, java.lang.String moduleResourceLocation)
static SingleNodeProcessingChainConsumer	chainConsumer(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain)
static SingleNodeProcessingChainConsumer	chainConsumer(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain, java.lang.String moduleResourceLocation)
static SingleNodeProcessingChainProducer	chainProducer(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain)
static SingleNodeProcessingChainProducer	chainProducer(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain, java.lang.String moduleResourceLocation)

Methods inherited from class java.lang.Object

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

Method Detail

chain

public static final SingleNodeProcessingChain chain(SingleNodeApplication application,
                              java.lang.String streamName,
                              java.lang.String processingChain)

Parameters:

application - the SingleNodeApplication to use

streamName - the name of the stream to create

processingChain - the partial stream definition DSL (no source or sink, only a processing chain}

Returns:

a SingleNodeProcessingChain

chain

public static final SingleNodeProcessingChain chain(SingleNodeApplication application,
                              java.lang.String streamName,
                              java.lang.String processingChain,
                              java.lang.String moduleResourceLocation)

Parameters:

application - the SingleNodeApplication to use

streamName - the name of the stream to create

processingChain - the partial stream definition DSL (no source or sink, only a processing chain}

moduleResourceLocation - a resource location pointing to a local directory from where module definitions may be registered

Returns:

a SingleNodeProcessingChain

chainConsumer

public static final SingleNodeProcessingChainConsumer chainConsumer(SingleNodeApplication application,
                                              java.lang.String streamName,
                                              java.lang.String processingChain)

Parameters:

application - the SingleNodeApplication to use

streamName - the name of the stream to create

processingChain - the partial stream definition DSL (must include a source and no sink}

Returns:

a SingleNodeProcessingChainConsumer

chainConsumer

public static final SingleNodeProcessingChainConsumer chainConsumer(SingleNodeApplication application,
                                              java.lang.String streamName,
                                              java.lang.String processingChain,
                                              java.lang.String moduleResourceLocation)

Parameters:

application - the SingleNodeApplication to use

streamName - the name of the stream to create

processingChain - the partial stream definition DSL (must include a source and no sink}

moduleResourceLocation - a resource location pointing to a local directory from where module definitions may be registered

Returns:

a SingleNodeProcessingChainConsumer

chainProducer

public static final SingleNodeProcessingChainProducer chainProducer(SingleNodeApplication application,
                                              java.lang.String streamName,
                                              java.lang.String processingChain)

Parameters:

application - the SingleNodeApplication to use

streamName - the name of the stream to create

processingChain - the partial stream definition DSL (must include a sink and no source}

Returns:

a SingleNodeProcessingChainProducer

chainProducer

public static final SingleNodeProcessingChainProducer chainProducer(SingleNodeApplication application,
                                              java.lang.String streamName,
                                              java.lang.String processingChain,
                                              java.lang.String moduleResourceLocation)

Parameters:

application - the SingleNodeApplication to use

streamName - the name of the stream to create

processingChain - the partial stream definition DSL (must include a sink and no source}

moduleResourceLocation - a resource location pointing to a local directory from where module definitions may be registered

Returns:

a SingleNodeProcessingChainProducer