org.springframework.xd.dirt.test.source

Class SingleNodeNamedQueueSource

java.lang.Object

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

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

org.springframework.xd.dirt.test.source.SingleNodeNamedQueueSource

All Implemented Interfaces:

NamedChannelModule, NamedChannelSource

public class SingleNodeNamedQueueSource
extends AbstractSingleNodeNamedChannelSource

A NamedChannelSource implementation that binds to a Queue Channel.

Author:

David Turanski

Field Summary

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

ALL_MEDIA_TYPES, messageBus, messageChannel, sharedChannelName

Constructor Summary

Constructors

Constructor and Description
SingleNodeNamedQueueSource(MessageBus messageBus, java.lang.String sharedChannelName)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	bind()

Methods inherited from class org.springframework.xd.dirt.test.source.AbstractSingleNodeNamedChannelSource

send, sendPayload, unbind

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleNodeNamedQueueSource

public SingleNodeNamedQueueSource(MessageBus messageBus,
                          java.lang.String sharedChannelName)

Method Detail

bind

protected void bind()

Specified by:

bind in class AbstractSingleNodeNamedChannelModule<org.springframework.messaging.SubscribableChannel>