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

Class BusTopicBase

java.lang.Object

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

All Implemented Interfaces:

BusTopic, Topic

Direct Known Subclasses:

InlineBusTopicSink, SingleThreadedBusTopicSource

public abstract class BusTopicBase
extends Object
implements BusTopic, Topic

Nested Class Summary

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

Topic.CommInfrastructure

Field Summary

Fields

Modifier and Type	Field and Description
protected String	apiKey
protected String	apiSecret
protected org.apache.commons.collections4.queue.CircularFifoQueue<String>	recentEvents
protected List<String>	servers
protected String	topic

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

NETWORK_LOGGER

Constructor Summary

Constructors

Constructor and Description
BusTopicBase(List<String> servers, String topic, String apiKey, String apiSecret)

Method Summary

Modifier and Type	Method and Description
String	getApiKey()
String	getApiSecret()
String[]	getRecentEvents() get the more recent events in this topic entity
List<String>	getServers() return list of servers
String	getTopic() gets the topic name
String	toString()

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.Topic

getTopicCommInfrastructure

Field Detail

servers

protected List<String> servers

topic

protected String topic

apiKey

protected String apiKey

apiSecret

protected String apiSecret

recentEvents

protected org.apache.commons.collections4.queue.CircularFifoQueue<String> recentEvents

Constructor Detail

BusTopicBase

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

Throws:

IllegalArgumentException

Method Detail

getTopic

public String getTopic()

gets the topic name

Specified by:

getTopic in interface Topic

Returns:

topic name

getServers

public List<String> getServers()

return list of servers

Specified by:

getServers in interface Topic

Returns:

bus servers

getApiKey

public String getApiKey()

Specified by:

getApiKey in interface BusTopic

getApiSecret

public String getApiSecret()

Specified by:

getApiSecret in interface BusTopic

getRecentEvents

public String[] getRecentEvents()

Description copied from interface: Topic

get the more recent events in this topic entity

Specified by:

getRecentEvents in interface Topic

Returns:

the recentEvents

toString

public String toString()

Overrides:

toString in class Object