Uses of Interface
com.activeviam.risk.ref.source.dataloadcontroller.impl.SimpleSourceConfig.ITopicConfig

Packages that use SimpleSourceConfig.ITopicConfig

Package	Description
com.activeviam.risk.ref.cfg.impl
com.activeviam.risk.ref.source.dataloadcontroller.impl

Uses of SimpleSourceConfig.ITopicConfig in com.activeviam.risk.ref.cfg.impl

Methods in com.activeviam.risk.ref.cfg.impl that return SimpleSourceConfig.ITopicConfig

Modifier and Type	Method	Description
protected <I> SimpleSourceConfig.ITopicConfig<com.qfs.msg.csv.IFileInfo<Path>>	ACSVSourceConfig.createTopicConfig(String topic, String store, com.qfs.source.ITuplePublisher<com.qfs.msg.csv.IFileInfo<Path>> tuplePublisher)	Create an SimpleSourceConfig.ITopicConfig object.

Methods in com.activeviam.risk.ref.cfg.impl that return types with arguments of type SimpleSourceConfig.ITopicConfig

Modifier and Type	Method	Description
protected Map<String,SimpleSourceConfig.ITopicConfig<com.qfs.msg.csv.IFileInfo<Path>>>	ACSVSourceConfig.getTopicToPublisherMap()

Uses of SimpleSourceConfig.ITopicConfig in com.activeviam.risk.ref.source.dataloadcontroller.impl

Classes in com.activeviam.risk.ref.source.dataloadcontroller.impl that implement SimpleSourceConfig.ITopicConfig

Modifier and Type	Class	Description
class	TopicConfig<I>	Implementation of SimpleSourceConfig.ITopicConfig which uses an optional wrapper for creating the message channel using the store message channel factory.

Constructor parameters in com.activeviam.risk.ref.source.dataloadcontroller.impl with type arguments of type SimpleSourceConfig.ITopicConfig

Constructor	Description
SimpleCsvSourceConfig(com.qfs.source.impl.CSVMessageChannelFactory<I> messageChannelFactory, com.activeviam.tools.dataloadcontroller.core.source.csv.CsvScopedFetchSource<I> source, Map<String,SimpleSourceConfig.ITopicConfig<com.qfs.msg.csv.IFileInfo<I>>> topicConfigs)
SimpleJdbcSourceConfig(com.activeviam.tools.dataloadcontroller.core.source.jdbc.TupleMessageChannelFactory messageChannelFactory, com.activeviam.tools.dataloadcontroller.core.source.jdbc.IJdbcScopedFetchSource source, Map<String,SimpleSourceConfig.ITopicConfig<String>> topicConfigs)
SimpleSourceConfig(com.qfs.source.IStoreMessageChannelFactory<I,E> messageChannelFactory, com.activeviam.tools.dataloadcontroller.core.source.IFetchingDataSource<I,E> source, Map<String,SimpleSourceConfig.ITopicConfig<I>> topicConfigs)	Create a new instance