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

Interface BusConsumer

All Known Implementing Classes:

BusConsumer.CambriaConsumerWrapper, BusConsumer.DmaapConsumerWrapper

public interface BusConsumer

Wrapper around libraries to consume from message bus

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	BusConsumer.CambriaConsumerWrapper Cambria based consumer
static class	BusConsumer.DmaapConsumerWrapper MR based consumer

Method Summary

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

Method Detail

fetch

Iterable<String> fetch()
                throws Exception

fetch messages

Returns:

list of messages

Throws:

Exception - when error encountered by underlying libraries

close

void close()

close underlying library consumer