Interface SimpleSourceConfig.ITopicConfig<I>
-
- Type Parameters:
I
- type of the identifiers of messages.
- All Known Implementing Classes:
TopicConfig
- Enclosing class:
- SimpleSourceConfig<I,E>
public static interface SimpleSourceConfig.ITopicConfig<I>
A Message Channel Factory for a topic.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description <E> com.qfs.msg.IMessageChannel<I,E>
createChannel(com.qfs.source.IStoreMessageChannelFactory<I,E> messageChannelFactory)
Create amessage channel
using astore message channel factory
.Collection<String>
getTargetStores()
The target stores for the created channel.
-
-
-
Method Detail
-
createChannel
<E> com.qfs.msg.IMessageChannel<I,E> createChannel(com.qfs.source.IStoreMessageChannelFactory<I,E> messageChannelFactory)
Create amessage channel
using astore message channel factory
. This method provides the ability to add tuple publishers, configure/wrap the channel, or even create a composite channel.- Type Parameters:
E
- type of the data elements appended into message chunks.- Parameters:
messageChannelFactory
- the underlying factory for creating channels- Returns:
- the message channel.
-
getTargetStores
Collection<String> getTargetStores()
The target stores for the created channel.- Returns:
- the stores the channel will write to.
- See Also:
ITuplePublisher.getTargetStores()
-
-