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

Class SingleNodeProcessingChainConsumer

java.lang.Object

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

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

All Implemented Interfaces:

NamedChannelModule, NamedChannelSink

public class SingleNodeProcessingChainConsumer
extends AbstractSingleNodeProcessingChain
implements NamedChannelSink

Creates a stream to test a processing chain including a source but no sink and adds a NamedChannelSink 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
SingleNodeProcessingChainConsumer(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain)
SingleNodeProcessingChainConsumer(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()
org.springframework.messaging.Message<?>	receive()
org.springframework.messaging.Message<?>	receive(int timeout)
java.lang.Object	receivePayload()
java.lang.Object	receivePayload(int timeout)

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

SingleNodeProcessingChainConsumer

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

SingleNodeProcessingChainConsumer

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

Method Detail

receive

public org.springframework.messaging.Message<?> receive()

Specified by:

receive in interface NamedChannelSink

receive

public org.springframework.messaging.Message<?> receive(int timeout)

Specified by:

receive in interface NamedChannelSink

receivePayload

public java.lang.Object receivePayload()

Specified by:

receivePayload in interface NamedChannelSink

receivePayload

public java.lang.Object receivePayload(int timeout)

Specified by:

receivePayload in interface NamedChannelSink

createSink

protected boolean createSink()

Specified by:

createSink in class AbstractSingleNodeProcessingChain

createSource

protected boolean createSource()

Specified by:

createSource in class AbstractSingleNodeProcessingChain