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

Interface DmaapTopicSinkFactory

public interface DmaapTopicSinkFactory

DMAAP Topic Sink Factory

Method Summary

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

Method Detail

build

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

Instantiates a new DMAAP Topic Sink

Parameters:

servers - list of servers

topic - topic name

apiKey - API Key

apiSecret - API Secret

userName - AAF user name

password - AAF password

partitionKey - Consumer Group

managed - is this sink endpoint managed?

Returns:

an DMAAP Topic Sink

Throws:

IllegalArgumentException - if invalid parameters are present

build

List<DmaapTopicSink> build(Properties properties)
                    throws IllegalArgumentException

Creates an DMAAP Topic Sink based on properties files

Parameters:

properties - Properties containing initialization values

Returns:

an DMAAP Topic Sink

Throws:

IllegalArgumentException - if invalid parameters are present

build

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

Instantiates a new DMAAP Topic Sink

Parameters:

servers - list of servers

topic - topic name

Returns:

an DMAAP Topic Sink

Throws:

IllegalArgumentException - if invalid parameters are present

destroy

void destroy(String topic)

Destroys an DMAAP Topic Sink based on a topic

Parameters:

topic - topic name

Throws:

IllegalArgumentException - if invalid parameters are present

get

DmaapTopicSink get(String topic)
            throws IllegalArgumentException,
                   IllegalStateException

gets an DMAAP Topic Sink based on topic name

Parameters:

topic - the topic name

Returns:

an DMAAP Topic Sink with topic name

Throws:

IllegalArgumentException - if an invalid topic is provided

IllegalStateException - if the DMAAP Topic Reader is an incorrect state

inventory

List<DmaapTopicSink> inventory()

Provides a snapshot of the DMAAP Topic Sinks

Returns:

a list of the DMAAP Topic Sinks

destroy

void destroy()

Destroys all DMAAP Topic Sinks