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

Class SingleThreadedUebTopicSource

java.lang.Object

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

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

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

All Implemented Interfaces:

Runnable, BusTopic, BusTopicSource, UebTopicSource, Topic, TopicRegisterable, TopicSource, org.openecomp.policy.drools.properties.Lockable, org.openecomp.policy.drools.properties.Startable

public class SingleThreadedUebTopicSource
extends SingleThreadedBusTopicSource
implements UebTopicSource

This topic source implementation specializes in reading messages over an UEB Bus topic source and notifying its listeners

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

alive, busPollerThread, consumer, consumerGroup, consumerInstance, fetchLimit, fetchTimeout, locked, networkLogger, topicListeners

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

factory

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

DEFAULT_CONSUMER_INSTANCE, DEFAULT_LIMIT_FETCH, DEFAULT_TIMEOUT_MS_FETCH, NO_LIMIT_FETCH, NO_TIMEOUT_MS_FETCH

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

NETWORK_LOGGER

Constructor Summary

Constructors

Constructor and Description
SingleThreadedUebTopicSource(List<String> servers, String topic, String apiKey, String apiSecret, String consumerGroup, String consumerInstance, int fetchTimeout, int fetchLimit)

Method Summary

Modifier and Type	Method and Description
Topic.CommInfrastructure	getTopicCommInfrastructure() gets the communication infrastructure type
void	init() Initialize the Cambria client
String	toString()

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

broadcast, getConsumerGroup, getConsumerInstance, getFetchLimit, getFetchTimeout, isAlive, isLocked, lock, offer, register, run, shutdown, snapshotTopicListeners, start, stop, unlock, unregister

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

getConsumerGroup, getConsumerInstance, getFetchLimit, getFetchTimeout

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

getApiKey, getApiSecret

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

offer

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

register, unregister

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

SingleThreadedUebTopicSource

public SingleThreadedUebTopicSource(List<String> servers,
                                    String topic,
                                    String apiKey,
                                    String apiSecret,
                                    String consumerGroup,
                                    String consumerInstance,
                                    int fetchTimeout,
                                    int fetchLimit)
                             throws IllegalArgumentException

Parameters:

servers - UEB servers

topic - UEB Topic to be monitored

apiKey - UEB API Key (optional)

apiSecret - UEB API Secret (optional)

consumerGroup - UEB Reader Consumer Group

consumerInstance - UEB Reader Instance

fetchTimeout - UEB fetch timeout

fetchLimit - UEB fetch limit

Throws:

IllegalArgumentException - An invalid parameter passed in

Method Detail

init

public void init()

Initialize the Cambria client

Specified by:

init in class SingleThreadedBusTopicSource

getTopicCommInfrastructure

public Topic.CommInfrastructure getTopicCommInfrastructure()

gets the communication infrastructure type

Specified by:

getTopicCommInfrastructure in interface Topic

Returns:

toString

public String toString()

Overrides:

toString in class SingleThreadedBusTopicSource