| Package | Description |
|---|---|
| io.openmessaging | |
| io.openmessaging.producer |
| Modifier and Type | Interface and Description |
|---|---|
interface |
Promise<V>
Special
Future which is writable. |
| Modifier and Type | Method and Description |
|---|---|
void |
FutureListener.operationComplete(Future<V> future)
Invoked when the operation completes, be the associated
Promise successful or not. |
| Modifier and Type | Method and Description |
|---|---|
Future<SendResult> |
Producer.sendAsync(List<Message> messages)
Send messages to the specified destination asynchronously, the destination should be preset to
Message.header(), other header fields as well. |
Future<SendResult> |
Producer.sendAsync(Message message)
Sends a message to the specified destination asynchronously, the destination should be preset to
Message.header(), other header fields as well. |
Copyright © 2017–2020 OpenMessaging. All rights reserved.