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

Class InlineUebTopicSink

java.lang.Object

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

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

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

All Implemented Interfaces:

BusTopic, BusTopicSink, UebTopicSink, Topic, TopicSink, org.openecomp.policy.drools.properties.Lockable, org.openecomp.policy.drools.properties.Startable

public class InlineUebTopicSink
extends InlineBusTopicSink
implements UebTopicSink

This implementation publishes events for the associated UEB topic, inline with the calling thread.

Nested Class Summary

Nested classes/interfaces inherited from interface org.openecomp.policy.drools.event.comm.Topic

Topic.CommInfrastructure

Field Summary

Fields inherited from class org.openecomp.policy.drools.event.comm.bus.internal.InlineBusTopicSink

alive, locked, networkLogger, partitionId, publisher

Fields inherited from class org.openecomp.policy.drools.event.comm.bus.internal.BusTopicBase

apiKey, apiSecret, recentEvents, servers, topic

Fields inherited from interface org.openecomp.policy.drools.event.comm.bus.UebTopicSink

factory

Fields inherited from interface org.openecomp.policy.drools.event.comm.bus.BusTopicSink

DEFAULT_LOG_SEND_FAILURES_AFTER

Fields inherited from interface org.openecomp.policy.drools.event.comm.Topic

NETWORK_LOGGER

Constructor Summary

Constructors

Constructor and Description
InlineUebTopicSink(List<String> servers, String topic, String apiKey, String apiSecret, String partitionId) Argument-based UEB Topic Writer instantiation

Method Summary

Modifier and Type	Method and Description
Topic.CommInfrastructure	getTopicCommInfrastructure() gets the communication infrastructure type
void	init() Instantiation of internal resources
String	toString()

Methods inherited from class org.openecomp.policy.drools.event.comm.bus.internal.InlineBusTopicSink

getPartitionKey, isAlive, isLocked, lock, send, setPartitionKey, shutdown, start, stop, unlock

Methods inherited from class org.openecomp.policy.drools.event.comm.bus.internal.BusTopicBase

getApiKey, getApiSecret, getRecentEvents, getServers, getTopic

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.openecomp.policy.drools.event.comm.bus.BusTopicSink

getPartitionKey, setPartitionKey

Methods inherited from interface org.openecomp.policy.drools.event.comm.bus.BusTopic

getApiKey, getApiSecret

Methods inherited from interface org.openecomp.policy.drools.event.comm.TopicSink

send

Methods inherited from interface org.openecomp.policy.drools.event.comm.Topic

getRecentEvents, getServers, getTopic

Methods inherited from interface org.openecomp.policy.drools.properties.Startable

isAlive, shutdown, start, stop

Methods inherited from interface org.openecomp.policy.drools.properties.Lockable

isLocked, lock, unlock

Constructor Detail

InlineUebTopicSink

public InlineUebTopicSink(List<String> servers,
                          String topic,
                          String apiKey,
                          String apiSecret,
                          String partitionId)
                   throws IllegalArgumentException

Argument-based UEB Topic Writer instantiation

Parameters:

servers - list of UEB servers available for publishing

topic - the topic to publish to

apiKey - the api key (optional)

apiSecret - the api secret (optional)

partitionId - the partition key (optional, autogenerated if not provided)

Throws:

IllegalArgumentException - if invalid arguments are detected

Method Detail

init

public void init()

Instantiation of internal resources

Specified by:

init in class InlineBusTopicSink

toString

public String toString()

Overrides:

toString in class BusTopicBase

getTopicCommInfrastructure

public Topic.CommInfrastructure getTopicCommInfrastructure()

gets the communication infrastructure type

Specified by:

getTopicCommInfrastructure in interface Topic

Specified by:

getTopicCommInfrastructure in class InlineBusTopicSink

Returns: