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

Class SingleNodeProcessingChainProducer

java.lang.Object

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

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

All Implemented Interfaces:

NamedChannelModule, NamedChannelSource

public class SingleNodeProcessingChainProducer
extends AbstractSingleNodeProcessingChain
implements NamedChannelSource

Creates a stream to test a processing chain including a sink but no source and adds a NamedChannelSource to create a complete stream.

Author:

David Turanski

Field Summary

Fields inherited from class org.springframework.xd.dirt.integration.test.process.AbstractSingleNodeProcessingChain

integrationSupport, sink, source

Constructor Summary

Constructors

Constructor and Description
SingleNodeProcessingChainProducer(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain)
SingleNodeProcessingChainProducer(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain, java.lang.String moduleResourceLocation)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	createSink()
protected boolean	createSource()
void	send(org.springframework.messaging.Message<?> message)
void	sendPayload(java.lang.Object payload)

Methods inherited from class org.springframework.xd.dirt.integration.test.process.AbstractSingleNodeProcessingChain

destroy, unbind

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.xd.dirt.integration.test.NamedChannelModule

unbind

Constructor Detail

SingleNodeProcessingChainProducer

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

SingleNodeProcessingChainProducer

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

Method Detail

send

public void send(org.springframework.messaging.Message<?> message)

Specified by:

send in interface NamedChannelSource

sendPayload

public void sendPayload(java.lang.Object payload)

Specified by:

sendPayload in interface NamedChannelSource

createSink

protected boolean createSink()

Specified by:

createSink in class AbstractSingleNodeProcessingChain

createSource

protected boolean createSource()

Specified by:

createSource in class AbstractSingleNodeProcessingChain