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

Interface BusTopicSource

All Superinterfaces:

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

All Known Subinterfaces:

DmaapTopicSource, UebTopicSource

All Known Implementing Classes:

SingleThreadedBusTopicSource, SingleThreadedDmaapTopicSource, SingleThreadedUebTopicSource

public interface BusTopicSource
extends BusTopic, TopicSource

Generic Topic Source for UEB/DMAAP Communication Infrastructure

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
static String	DEFAULT_CONSUMER_INSTANCE Default Consumer Instance Value
static int	DEFAULT_LIMIT_FETCH Default maximum number of messages fetch at the time
static int	DEFAULT_TIMEOUT_MS_FETCH Default Timeout fetching in milliseconds
static int	NO_LIMIT_FETCH Definition of No limit fetching
static int	NO_TIMEOUT_MS_FETCH Definition of No Timeout fetching

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

NETWORK_LOGGER

Method Summary

Modifier and Type	Method and Description
String	getConsumerGroup() gets the consumer group
String	getConsumerInstance() gets the consumer instance
int	getFetchLimit() gets the fetch limit
int	getFetchTimeout() gets the fetch timeout

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, getTopicCommInfrastructure

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

Field Detail

DEFAULT_CONSUMER_INSTANCE

static final String DEFAULT_CONSUMER_INSTANCE

Default Consumer Instance Value

See Also:

Constant Field Values

DEFAULT_TIMEOUT_MS_FETCH

static final int DEFAULT_TIMEOUT_MS_FETCH

Default Timeout fetching in milliseconds

See Also:

Constant Field Values

DEFAULT_LIMIT_FETCH

static final int DEFAULT_LIMIT_FETCH

Default maximum number of messages fetch at the time

See Also:

Constant Field Values

NO_TIMEOUT_MS_FETCH

static final int NO_TIMEOUT_MS_FETCH

Definition of No Timeout fetching

See Also:

Constant Field Values

NO_LIMIT_FETCH

static final int NO_LIMIT_FETCH

Definition of No limit fetching

See Also:

Constant Field Values

Method Detail

getConsumerGroup

String getConsumerGroup()

gets the consumer group

Returns:

consumer group

getConsumerInstance

String getConsumerInstance()

gets the consumer instance

Returns:

consumer instance

getFetchTimeout

int getFetchTimeout()

gets the fetch timeout

Returns:

fetch timeout

getFetchLimit

int getFetchLimit()

gets the fetch limit

Returns:

fetch limit