public class SingleNodeNamedChannelSinkFactory extends AbstractSingleNodeNamedChannelModuleFactory
NamedChannelSinks.messageBus, QUEUE_PREFIX, TOPIC_PREFIX| Constructor and Description |
|---|
SingleNodeNamedChannelSinkFactory(MessageBus messageBus) |
| Modifier and Type | Method and Description |
|---|---|
NamedChannelSink |
createNamedChannelSink(java.lang.String channelName) |
validateChannelNamepublic SingleNodeNamedChannelSinkFactory(MessageBus messageBus)
public NamedChannelSink createNamedChannelSink(java.lang.String channelName)