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 Detail

      • createChannel

        <E> com.qfs.msg.IMessageChannel<I,​E> createChannel​(com.qfs.source.IStoreMessageChannelFactory<I,​E> messageChannelFactory)
        Create a message channel using a store 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()