org.springframework.xd.dirt.test.source

Class SingleNodeNamedTopicSource

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.SingleNodeNamedTopicSource

All Implemented Interfaces:

NamedChannelModule, NamedChannelSource

public class SingleNodeNamedTopicSource
extends AbstractSingleNodeNamedChannelSource

A NamedChannelSource implementation that binds to a PubSub 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
SingleNodeNamedTopicSource(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

SingleNodeNamedTopicSource

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

Method Detail

bind

protected void bind()

Specified by:

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