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

Interface DmaapTopicSourceFactory

public interface DmaapTopicSourceFactory

DMAAP Topic Source Factory

Method Summary

Modifier and Type	Method and Description
DmaapTopicSource	build(List<String> servers, String topic) Instantiates a new DMAAP Topic Source
DmaapTopicSource	build(List<String> servers, String topic, String apiKey, String apiSecret) Instantiates a new DMAAP Topic Source
DmaapTopicSource	build(List<String> servers, String topic, String apiKey, String apiSecret, String userName, String password, String consumerGroup, String consumerInstance, int fetchTimeout, int fetchLimit, boolean managed) Instantiates a new DMAAP Topic Source
List<DmaapTopicSource>	build(Properties properties) Creates an DMAAP Topic Source based on properties files
void	destroy() Destroys all DMAAP Topic Sources
void	destroy(String topic) Destroys an DMAAP Topic Source based on a topic
DmaapTopicSource	get(String topic) gets an DMAAP Topic Source based on topic name
List<DmaapTopicSource>	inventory() Provides a snapshot of the DMAAP Topic Sources

Method Detail

build

List<DmaapTopicSource> build(Properties properties)
                      throws IllegalArgumentException

Creates an DMAAP Topic Source based on properties files

Parameters:

properties - Properties containing initialization values

Returns:

an DMAAP Topic Source

Throws:

IllegalArgumentException - if invalid parameters are present

build

DmaapTopicSource build(List<String> servers,
                       String topic,
                       String apiKey,
                       String apiSecret,
                       String userName,
                       String password,
                       String consumerGroup,
                       String consumerInstance,
                       int fetchTimeout,
                       int fetchLimit,
                       boolean managed)
                throws IllegalArgumentException

Instantiates a new DMAAP Topic Source

Parameters:

servers - list of servers

topic - topic name

apiKey - API Key

apiSecret - API Secret

userName - user name

password - password

consumerGroup - Consumer Group

consumerInstance - Consumer Instance

fetchTimeout - Read Fetch Timeout

fetchLimit - Fetch Limit

managed - is this endpoind managed?

Returns:

an DMAAP Topic Source

Throws:

IllegalArgumentException - if invalid parameters are present

build

DmaapTopicSource build(List<String> servers,
                       String topic,
                       String apiKey,
                       String apiSecret)
                throws IllegalArgumentException

Instantiates a new DMAAP Topic Source

Parameters:

servers - list of servers

topic - topic name

apiKey - API Key

apiSecret - API Secret

Returns:

an DMAAP Topic Source

Throws:

IllegalArgumentException - if invalid parameters are present

build

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

Instantiates a new DMAAP Topic Source

Parameters:

uebTopicReaderType - Implementation type

servers - list of servers

topic - topic name

Returns:

an DMAAP Topic Source

Throws:

IllegalArgumentException - if invalid parameters are present

destroy

void destroy(String topic)

Destroys an DMAAP Topic Source based on a topic

Parameters:

topic - topic name

Throws:

IllegalArgumentException - if invalid parameters are present

destroy

void destroy()

Destroys all DMAAP Topic Sources

get

DmaapTopicSource get(String topic)
              throws IllegalArgumentException,
                     IllegalStateException

gets an DMAAP Topic Source based on topic name

Parameters:

topic - the topic name

Returns:

an DMAAP Topic Source with topic name

Throws:

IllegalArgumentException - if an invalid topic is provided

IllegalStateException - if the DMAAP Topic Source is an incorrect state

inventory

List<DmaapTopicSource> inventory()

Provides a snapshot of the DMAAP Topic Sources

Returns:

a list of the DMAAP Topic Sources