Package | Description |
---|---|
io.openmessaging.producer |
Modifier and Type | Interface and Description |
---|---|
interface |
TransactionalResult
The result of sending a OMS prepare message to server with the message id, this result can be used to commits or or
rolls back a prepare message.
|
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.header() , other header fields as well. |
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.