Package | Description |
---|---|
org.openecomp.policy.drools.event.comm | |
org.openecomp.policy.drools.event.comm.bus | |
org.openecomp.policy.drools.event.comm.bus.internal |
Modifier and Type | Method and Description |
---|---|
DmaapTopicSource |
TopicEndpoint.getDmaapTopicSource(String topicName)
get the DMAAP Topic Source for the given topic name
|
Modifier and Type | Method and Description |
---|---|
List<DmaapTopicSource> |
TopicEndpoint.getDmaapTopicSources()
gets only the DMAAP Topic Sources
|
Modifier and Type | Method and Description |
---|---|
DmaapTopicSource |
DmaapTopicSourceFactory.build(List<String> servers,
String topic)
Instantiates a new DMAAP Topic Source
|
DmaapTopicSource |
DmaapTopicSourceFactory.build(List<String> servers,
String topic,
String apiKey,
String apiSecret)
Instantiates a new DMAAP Topic Source
|
DmaapTopicSource |
DmaapTopicSourceFactory.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
|
DmaapTopicSource |
DmaapTopicSourceFactory.get(String topic)
gets an DMAAP Topic Source based on topic name
|
Modifier and Type | Method and Description |
---|---|
List<DmaapTopicSource> |
DmaapTopicSourceFactory.build(Properties properties)
Creates an DMAAP Topic Source based on properties files
|
List<DmaapTopicSource> |
DmaapTopicSourceFactory.inventory()
Provides a snapshot of the DMAAP Topic Sources
|
Modifier and Type | Class and Description |
---|---|
class |
SingleThreadedDmaapTopicSource
This topic reader implementation specializes in reading messages
over DMAAP topic and notifying its listeners
|
Copyright © 2018. All rights reserved.