public interface BusPublisher
Modifier and Type | Interface and Description |
---|---|
static class |
BusPublisher.CambriaPublisherWrapper
Cambria based library publisher
|
static class |
BusPublisher.DmaapPublisherWrapper
DmaapClient library wrapper
|
Modifier and Type | Method and Description |
---|---|
void |
close()
closes the publisher
|
boolean |
send(String partitionId,
String message)
sends a message
|
boolean send(String partitionId, String message) throws IllegalArgumentException
partition
- idmessage
- the messageIllegalArgumentException
- if no message providedvoid close()
Copyright © 2018. All rights reserved.