public static class BusPublisher.DmaapPublisherWrapper extends Object implements BusPublisher
BusPublisher.CambriaPublisherWrapper, BusPublisher.DmaapPublisherWrapper
Modifier and Type | Field and Description |
---|---|
protected com.att.nsa.mr.client.impl.MRSimplerBatchPublisher |
publisher
MR based Publisher
|
Constructor and Description |
---|
DmaapPublisherWrapper(List<String> servers,
String topic,
String aafLogin,
String aafPassword) |
Modifier and Type | Method and Description |
---|---|
void |
close()
closes the publisher
|
boolean |
send(String partitionId,
String message)
sends a message
|
String |
toString() |
protected com.att.nsa.mr.client.impl.MRSimplerBatchPublisher publisher
public void close()
close
in interface BusPublisher
public boolean send(String partitionId, String message) throws IllegalArgumentException
send
in interface BusPublisher
message
- the messageIllegalArgumentException
- if no message providedCopyright © 2018. All rights reserved.