| Package | Description |
|---|---|
| io.openmessaging.producer |
| Modifier and Type | Method and Description |
|---|---|
SendResult |
Producer.send(Message message)
Sends a message to the specified destination synchronously, the destination should be preset to
Message.sysHeaders(), other header fields as well. |
SendResult |
Producer.send(Message message,
KeyValue attributes)
Sends a message to the specified destination synchronously, using the specified attributes, the destination
should be preset to
Message.sysHeaders(), other header fields as well. |
SendResult |
Producer.send(Message message,
LocalTransactionExecutor branchExecutor,
KeyValue attributes)
Sends a transactional message to the specified destination synchronously, using the specified attributes,
the destination should be preset to
Message.sysHeaders(), other header fields as well. |
| Modifier and Type | Method and Description |
|---|---|
Future<SendResult> |
Producer.sendAsync(Message message)
Sends a message to the specified destination asynchronously, the destination should be preset to
Message.sysHeaders(), other header fields as well. |
Future<SendResult> |
Producer.sendAsync(Message message,
KeyValue attributes)
Sends a message to the specified destination asynchronously, using the specified attributes, the destination
should be preset to
Message.sysHeaders(), other header fields as well. |
Copyright © 2017–2018 OpenMessaging. All rights reserved.