org.openecomp.policy.drools.event.comm.bus

Interface UebTopicSinkFactory

public interface UebTopicSinkFactory

UEB Topic Sink Factory

Method Summary

Modifier and Type	Method and Description
UebTopicSink	build(List<String> servers, String topic) Instantiates a new UEB Topic Writer
UebTopicSink	build(List<String> servers, String topic, String apiKey, String apiSecret, String partitionKey, boolean managed) Instantiates a new UEB Topic Writer
List<UebTopicSink>	build(Properties properties) Creates an UEB Topic Writer based on properties files
void	destroy() Destroys all UEB Topic Writers
void	destroy(String topic) Destroys an UEB Topic Writer based on a topic
UebTopicSink	get(String topic) gets an UEB Topic Writer based on topic name
List<UebTopicSink>	inventory() Provides a snapshot of the UEB Topic Writers

Method Detail

build

UebTopicSink build(List<String> servers,
                   String topic,
                   String apiKey,
                   String apiSecret,
                   String partitionKey,
                   boolean managed)
            throws IllegalArgumentException

Instantiates a new UEB Topic Writer

Parameters:

servers - list of servers

topic - topic name

apiKey - API Key

apiSecret - API Secret

partitionKey - Consumer Group

managed - is this sink endpoint managed?

Returns:

an UEB Topic Writer

Throws:

IllegalArgumentException - if invalid parameters are present

build

List<UebTopicSink> build(Properties properties)
                  throws IllegalArgumentException

Creates an UEB Topic Writer based on properties files

Parameters:

properties - Properties containing initialization values

Returns:

an UEB Topic Writer

Throws:

IllegalArgumentException - if invalid parameters are present

build

UebTopicSink build(List<String> servers,
                   String topic)
            throws IllegalArgumentException

Instantiates a new UEB Topic Writer

Parameters:

servers - list of servers

topic - topic name

Returns:

an UEB Topic Writer

Throws:

IllegalArgumentException - if invalid parameters are present

destroy

void destroy(String topic)

Destroys an UEB Topic Writer based on a topic

Parameters:

topic - topic name

Throws:

IllegalArgumentException - if invalid parameters are present

get

UebTopicSink get(String topic)
          throws IllegalArgumentException,
                 IllegalStateException

gets an UEB Topic Writer based on topic name

Parameters:

topic - the topic name

Returns:

an UEB Topic Writer with topic name

Throws:

IllegalArgumentException - if an invalid topic is provided

IllegalStateException - if the UEB Topic Reader is an incorrect state

inventory

List<UebTopicSink> inventory()

Provides a snapshot of the UEB Topic Writers

Returns:

a list of the UEB Topic Writers

destroy

void destroy()

Destroys all UEB Topic Writers