org.springframework.xd.dirt.test.sink

Class SingleNodeNamedTopicSink

java.lang.Object

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

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

org.springframework.xd.dirt.test.sink.SingleNodeNamedTopicSink

All Implemented Interfaces:

NamedChannelModule, NamedChannelSink

public class SingleNodeNamedTopicSink
extends AbstractSingleNodeNamedChannelSink

A NamedChannelSink 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

Modifier	Constructor and Description
protected	SingleNodeNamedTopicSink(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.sink.AbstractSingleNodeNamedChannelSink

receive, receivePayload, unbind

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleNodeNamedTopicSink

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

Method Detail

bind

protected void bind()

Specified by:

bind in class AbstractSingleNodeNamedChannelModule<org.springframework.integration.channel.QueueChannel>