org.springframework.xd.dirt.test.sink

Class AbstractSingleNodeNamedChannelSink

java.lang.Object

org.springframework.xd.dirt.test.AbstractSingleNodeNamedChannelModule<org.springframework.integration.channel.QueueChannel>

org.springframework.xd.dirt.test.sink.AbstractSingleNodeNamedChannelSink

All Implemented Interfaces:

NamedChannelModule, NamedChannelSink

Direct Known Subclasses:

SingleNodeNamedQueueSink, SingleNodeNamedTopicSink

public abstract class AbstractSingleNodeNamedChannelSink
extends AbstractSingleNodeNamedChannelModule<org.springframework.integration.channel.QueueChannel>
implements NamedChannelSink

Base class for SingleNode named channel sink types.

Author:

David Turanski

Field Summary

Fields inherited from class org.springframework.xd.dirt.test.AbstractSingleNodeNamedChannelModule

ALL_MEDIA_TYPES, messageBus, messageChannel, sharedChannelName

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractSingleNodeNamedChannelSink(MessageBus messageBus, java.lang.String sharedChannelName)

Method Summary

Methods

Modifier and Type	Method and Description
org.springframework.messaging.Message<?>	receive()
org.springframework.messaging.Message<?>	receive(int timeout)
java.lang.Object	receivePayload()
java.lang.Object	receivePayload(int timeout)
void	unbind()

Methods inherited from class org.springframework.xd.dirt.test.AbstractSingleNodeNamedChannelModule

bind

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractSingleNodeNamedChannelSink

protected AbstractSingleNodeNamedChannelSink(MessageBus messageBus,
                                  java.lang.String sharedChannelName)

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

unbind

public void unbind()

Specified by:

unbind in interface NamedChannelModule