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 |
---|---|
TopicSink |
TopicEndpoint.getTopicSink(Topic.CommInfrastructure commType,
String topicName)
get the Topic Sinks for the given topic name and
underlying communication infrastructure type
|
Modifier and Type | Method and Description |
---|---|
List<? extends TopicSink> |
TopicEndpoint.addTopicSinks(Properties properties)
Add Topic Sinks to the communication infrastructure initialized per
properties
|
List<? extends TopicSink> |
TopicEndpoint.getTopicSinks()
gets all Topic Sinks
|
List<? extends TopicSink> |
TopicEndpoint.getTopicSinks(List<String> topicNames)
get the Topic Sinks for the given topic name
|
List<? extends TopicSink> |
TopicEndpoint.getTopicSinks(String topicName)
get the Topic Sinks for the given topic name and
all the underlying communication infrastructure type
|
Modifier and Type | Interface and Description |
---|---|
interface |
BusTopicSink
Topic Sink over Bus Infrastructure (DMAAP/UEB)
|
interface |
DmaapTopicSink |
interface |
UebTopicSink
Topic Writer over UEB Infrastructure
|
Modifier and Type | Class and Description |
---|---|
class |
InlineBusTopicSink
Transport Agnostic Bus Topic Sink to carry out the core functionality
to interact with a sink regardless if it is UEB or DMaaP.
|
class |
InlineDmaapTopicSink
This implementation publishes events for the associated DMAAP topic,
inline with the calling thread.
|
class |
InlineUebTopicSink
This implementation publishes events for the associated UEB topic,
inline with the calling thread.
|
Copyright © 2018. All rights reserved.