org.springframework.xd.dirt.integration.test.process

Class AbstractSingleNodeProcessingChain

java.lang.Object

org.springframework.xd.dirt.integration.test.process.AbstractSingleNodeProcessingChain

Direct Known Subclasses:

SingleNodeProcessingChain, SingleNodeProcessingChainConsumer, SingleNodeProcessingChainProducer

public abstract class AbstractSingleNodeProcessingChain
extends java.lang.Object

A helper class for building single node streams that use a NamedChannelSource and NamedChannelSink.

Author:

David Turanski

Field Summary

Fields

Modifier and Type	Field and Description
protected SingleNodeIntegrationTestSupport	integrationSupport
protected NamedChannelSink	sink
protected NamedChannelSource	source

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractSingleNodeProcessingChain(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain)
protected	AbstractSingleNodeProcessingChain(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain, java.lang.String moduleResourceLocation)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract boolean	createSink()
protected abstract boolean	createSource()
void	destroy()
void	unbind()

Methods inherited from class java.lang.Object

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

Field Detail

source

protected final NamedChannelSource source

sink

protected final NamedChannelSink sink

integrationSupport

protected final SingleNodeIntegrationTestSupport integrationSupport

Constructor Detail

AbstractSingleNodeProcessingChain

protected AbstractSingleNodeProcessingChain(SingleNodeApplication application,
                                 java.lang.String streamName,
                                 java.lang.String processingChain)

AbstractSingleNodeProcessingChain

protected AbstractSingleNodeProcessingChain(SingleNodeApplication application,
                                 java.lang.String streamName,
                                 java.lang.String processingChain,
                                 java.lang.String moduleResourceLocation)

Method Detail

unbind

public void unbind()

destroy

public void destroy()

createSink

protected abstract boolean createSink()

createSource

protected abstract boolean createSource()