org.springframework.xd.dirt.test.sink

Class SingleNodeNamedQueueSink

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

All Implemented Interfaces:

NamedChannelModule, NamedChannelSink

public class SingleNodeNamedQueueSink
extends AbstractSingleNodeNamedChannelSink

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

SingleNodeNamedQueueSink

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

Method Detail

bind

protected void bind()

Specified by:

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