public static class BusConsumer.CambriaConsumerWrapper extends Object implements BusConsumer
BusConsumer.CambriaConsumerWrapper, BusConsumer.DmaapConsumerWrapper
Modifier and Type | Field and Description |
---|---|
protected com.att.nsa.cambria.client.CambriaConsumer |
consumer
Cambria client
|
Constructor and Description |
---|
CambriaConsumerWrapper(List<String> servers,
String topic,
String apiKey,
String apiSecret,
String consumerGroup,
String consumerInstance,
int fetchTimeout,
int fetchLimit)
Cambria Consumer Wrapper
|
Modifier and Type | Method and Description |
---|---|
void |
close()
close underlying library consumer
|
Iterable<String> |
fetch()
fetch messages
|
String |
toString() |
public CambriaConsumerWrapper(List<String> servers, String topic, String apiKey, String apiSecret, String consumerGroup, String consumerInstance, int fetchTimeout, int fetchLimit) throws IllegalArgumentException
servers
- messaging bus hoststopic
- topicapiKey
- API KeyapiSecret
- API SecretconsumerGroup
- Consumer GroupconsumerInstance
- Consumer InstancefetchTimeout
- Fetch TimeoutfetchLimit
- Fetch LimitGeneralSecurityException
MalformedURLException
IllegalArgumentException
public Iterable<String> fetch() throws Exception
fetch
in interface BusConsumer
Exception
- when error encountered by underlying librariespublic void close()
close
in interface BusConsumer
Copyright © 2018. All rights reserved.