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

Class TopicConfig<I>

java.lang.Object

com.activeviam.risk.ref.source.dataloadcontroller.impl.TopicConfig<I>

Type Parameters:

I - type of the identifiers of messages.

All Implemented Interfaces:

SimpleSourceConfig.ITopicConfig<I>

public class TopicConfig<I>
extends Object
implements SimpleSourceConfig.ITopicConfig<I>

Implementation of SimpleSourceConfig.ITopicConfig which uses an optional wrapper for creating the message channel using the store message channel factory.

Field Summary

Fields

Modifier and Type	Field	Description
Function<com.qfs.source.IStoreMessageChannelFactory<I,?>,com.qfs.msg.IMessageChannel<I,?>>	messageChannelFactory
String	name
String	store
com.qfs.source.ITuplePublisher<I>	tuplePublisher

Constructor Summary

Constructors

Constructor	Description
TopicConfig(String name, String store, com.qfs.source.ITuplePublisher<I> tuplePublisher)
TopicConfig(String name, String store, com.qfs.source.ITuplePublisher<I> tuplePublisher, Function<com.qfs.source.IStoreMessageChannelFactory<I,?>,com.qfs.msg.IMessageChannel<I,?>> messageChannelFactory)

Method Summary

Modifier and Type	Method	Description
<E> com.qfs.msg.IMessageChannel<I,E>	createChannel(com.qfs.source.IStoreMessageChannelFactory<I,E> messageChannelFactory)	Create a message channel using messageChannelFactory if it is set, otherwise use messageChannelFactory.
static <I,E> com.qfs.source.IStoreMessageChannel<I,E>	createChannel(com.qfs.source.IStoreMessageChannelFactory<I,E> messageChannelFactory, String name, String store, com.qfs.source.ITuplePublisher<I> tuplePublisher)
Collection<String>	getTargetStores()	The target stores for the created channel.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

name

public final String name

store

public final String store

tuplePublisher

public final com.qfs.source.ITuplePublisher<I> tuplePublisher

messageChannelFactory

public final Function<com.qfs.source.IStoreMessageChannelFactory<I,?>,com.qfs.msg.IMessageChannel<I,?>> messageChannelFactory

Constructor Detail

TopicConfig

public TopicConfig(String name,
                   String store,
                   com.qfs.source.ITuplePublisher<I> tuplePublisher)

TopicConfig

public TopicConfig(String name,
                   String store,
                   com.qfs.source.ITuplePublisher<I> tuplePublisher,
                   Function<com.qfs.source.IStoreMessageChannelFactory<I,?>,com.qfs.msg.IMessageChannel<I,?>> messageChannelFactory)

Method Detail

getTargetStores

public Collection<String> getTargetStores()

Description copied from interface: SimpleSourceConfig.ITopicConfig

The target stores for the created channel.

Specified by:

getTargetStores in interface SimpleSourceConfig.ITopicConfig<I>

Returns:

the stores the channel will write to.

See Also:

ITuplePublisher.getTargetStores()

createChannel

public <E> com.qfs.msg.IMessageChannel<I,E> createChannel(com.qfs.source.IStoreMessageChannelFactory<I,E> messageChannelFactory)

Create a message channel using messageChannelFactory if it is set, otherwise use messageChannelFactory.

Specified by:

createChannel in interface SimpleSourceConfig.ITopicConfig<I>

Type Parameters:

E - type of the data elements appended into message chunks.

Parameters:

messageChannelFactory - the store message channel factory

Returns:

the message channel

createChannel

public static <I,E> com.qfs.source.IStoreMessageChannel<I,E> createChannel(com.qfs.source.IStoreMessageChannelFactory<I,E> messageChannelFactory,
                                                                                       String name,
                                                                                       String store,
                                                                                       com.qfs.source.ITuplePublisher<I> tuplePublisher)