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

Class SingleThreadedDmaapTopicSource

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

All Implemented Interfaces:

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

public class SingleThreadedDmaapTopicSource
extends SingleThreadedBusTopicSource
implements DmaapTopicSource, Runnable

This topic reader implementation specializes in reading messages over DMAAP topic 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

Modifier and Type	Field and Description
protected String	password
protected String	userName

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

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
SingleThreadedDmaapTopicSource(List<String> servers, String topic, String apiKey, String apiSecret, String userName, String password, 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 or MR 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

Methods inherited from interface java.lang.Runnable

run

Field Detail

userName

protected final String userName

password

protected final String password

Constructor Detail

SingleThreadedDmaapTopicSource

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

Parameters:

servers - DMaaP servers

topic - DMaaP Topic to be monitored

apiKey - DMaaP API Key (optional)

apiSecret - DMaaP API Secret (optional)

consumerGroup - DMaaP Reader Consumer Group

consumerInstance - DMaaP Reader Instance

fetchTimeout - DMaaP fetch timeout

fetchLimit - DMaaP fetch limit

Throws:

IllegalArgumentException - An invalid parameter passed in

Method Detail

init

public void init()
          throws Exception

Initialize the Cambria or MR Client

Specified by:

init in class SingleThreadedBusTopicSource

Throws:

Exception

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