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

Class SingleNodeProcessingChain

java.lang.Object

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

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

All Implemented Interfaces:

NamedChannelModule, NamedChannelSink, NamedChannelSource

public class SingleNodeProcessingChain
extends AbstractSingleNodeProcessingChain
implements NamedChannelSource, NamedChannelSink

Creates a stream to test a processing chain "p1 | p2 ... | pn" adding a NamedChannelSink and NamedChannelSource.

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
SingleNodeProcessingChain(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain)
SingleNodeProcessingChain(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)
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

SingleNodeProcessingChain

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

SingleNodeProcessingChain

public SingleNodeProcessingChain(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

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