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

Class BusConsumer.DmaapConsumerWrapper

java.lang.Object

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

All Implemented Interfaces:

BusConsumer

Enclosing interface:

BusConsumer

public static class BusConsumer.DmaapConsumerWrapper
extends Object
implements BusConsumer

MR based consumer

Nested Class Summary

Nested classes/interfaces inherited from interface org.openecomp.policy.drools.event.comm.bus.internal.BusConsumer

BusConsumer.CambriaConsumerWrapper, BusConsumer.DmaapConsumerWrapper

Field Summary

Fields

Modifier and Type	Field and Description
protected com.att.nsa.mr.client.impl.MRConsumerImpl	consumer MR Consumer

Constructor Summary

Constructors

Constructor and Description
DmaapConsumerWrapper(List<String> servers, String topic, String apiKey, String apiSecret, String aafLogin, String aafPassword, String consumerGroup, String consumerInstance, int fetchTimeout, int fetchLimit) MR Consumer Wrapper

Method Summary

Modifier and Type	Method and Description
void	close() close underlying library consumer
Iterable<String>	fetch() fetch messages
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

consumer

protected com.att.nsa.mr.client.impl.MRConsumerImpl consumer

MR Consumer

Constructor Detail

DmaapConsumerWrapper

public DmaapConsumerWrapper(List<String> servers,
                            String topic,
                            String apiKey,
                            String apiSecret,
                            String aafLogin,
                            String aafPassword,
                            String consumerGroup,
                            String consumerInstance,
                            int fetchTimeout,
                            int fetchLimit)
                     throws Exception

MR Consumer Wrapper

Parameters:

servers - messaging bus hosts

topic - topic

apiKey - API Key

apiSecret - API Secret

aafLogin - AAF Login

aafPassword - AAF Password

consumerGroup - Consumer Group

consumerInstance - Consumer Instance

fetchTimeout - Fetch Timeout

fetchLimit - Fetch Limit

Throws:

Exception

Method Detail

fetch

public Iterable<String> fetch()
                       throws Exception

fetch messages

Specified by:

fetch in interface BusConsumer

Returns:

list of messages

Throws:

Exception - when error encountered by underlying libraries

close

public void close()

close underlying library consumer

Specified by:

close in interface BusConsumer

toString

public String toString()

Overrides:

toString in class Object