public interface UebTopicSourceFactory
Modifier and Type | Method and Description |
---|---|
UebTopicSource |
build(List<String> servers,
String topic)
Instantiates a new UEB Topic Source
|
UebTopicSource |
build(List<String> servers,
String topic,
String apiKey,
String apiSecret)
Instantiates a new UEB Topic Source
|
UebTopicSource |
build(List<String> servers,
String topic,
String apiKey,
String apiSecret,
String consumerGroup,
String consumerInstance,
int fetchTimeout,
int fetchLimit,
boolean managed)
Instantiates a new UEB Topic Source
|
List<UebTopicSource> |
build(Properties properties)
Creates an UEB Topic Source based on properties files
|
void |
destroy()
Destroys all UEB Topic Sources
|
void |
destroy(String topic)
Destroys an UEB Topic Source based on a topic
|
UebTopicSource |
get(String topic)
gets an UEB Topic Source based on topic name
|
List<UebTopicSource> |
inventory()
Provides a snapshot of the UEB Topic Sources
|
List<UebTopicSource> build(Properties properties) throws IllegalArgumentException
properties
- Properties containing initialization valuesIllegalArgumentException
- if invalid parameters are presentUebTopicSource build(List<String> servers, String topic, String apiKey, String apiSecret, String consumerGroup, String consumerInstance, int fetchTimeout, int fetchLimit, boolean managed) throws IllegalArgumentException
servers
- list of serverstopic
- topic nameapiKey
- API KeyapiSecret
- API SecretconsumerGroup
- Consumer GroupconsumerInstance
- Consumer InstancefetchTimeout
- Read Fetch TimeoutfetchLimit
- Fetch Limitmanaged
- is this source endpoint managed?IllegalArgumentException
- if invalid parameters are presentUebTopicSource build(List<String> servers, String topic, String apiKey, String apiSecret) throws IllegalArgumentException
servers
- list of serverstopic
- topic nameapiKey
- API KeyapiSecret
- API SecretIllegalArgumentException
- if invalid parameters are presentUebTopicSource build(List<String> servers, String topic) throws IllegalArgumentException
uebTopicSourceType
- Implementation typeservers
- list of serverstopic
- topic nameIllegalArgumentException
- if invalid parameters are presentvoid destroy(String topic)
topic
- topic nameIllegalArgumentException
- if invalid parameters are presentvoid destroy()
UebTopicSource get(String topic) throws IllegalArgumentException, IllegalStateException
topic
- the topic nameIllegalArgumentException
- if an invalid topic is providedIllegalStateException
- if the UEB Topic Source is
an incorrect stateList<UebTopicSource> inventory()
Copyright © 2018. All rights reserved.