org.springframework.xd.dirt.test.source

Class AbstractSingleNodeNamedChannelSource

java.lang.Object

org.springframework.xd.dirt.test.AbstractSingleNodeNamedChannelModule<org.springframework.messaging.SubscribableChannel>

org.springframework.xd.dirt.test.source.AbstractSingleNodeNamedChannelSource

All Implemented Interfaces:

NamedChannelModule, NamedChannelSource

Direct Known Subclasses:

SingleNodeNamedQueueSource, SingleNodeNamedTopicSource

public abstract class AbstractSingleNodeNamedChannelSource
extends AbstractSingleNodeNamedChannelModule<org.springframework.messaging.SubscribableChannel>
implements NamedChannelSource

Base class for SingleNode named channel source 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	AbstractSingleNodeNamedChannelSource(MessageBus messageBus, org.springframework.messaging.SubscribableChannel messageChannel, java.lang.String sharedChannelName)

Method Summary

Methods

Modifier and Type	Method and Description
void	send(org.springframework.messaging.Message<?> message)
void	sendPayload(java.lang.Object payload)
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

AbstractSingleNodeNamedChannelSource

protected AbstractSingleNodeNamedChannelSource(MessageBus messageBus,
                                    org.springframework.messaging.SubscribableChannel messageChannel,
                                    java.lang.String sharedChannelName)

Method Detail

unbind

public void unbind()

Specified by:

unbind in interface NamedChannelModule

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