public interface ExtensionTransactionalResult
void
commit()
rollback()
List<io.openmessaging.producer.SendResult>
send(List<io.openmessaging.message.Message> messages)
io.openmessaging.producer.SendResult
send(io.openmessaging.message.Message message)
String
transactionId()
String transactionId()
void commit()
void rollback()
io.openmessaging.producer.SendResult send(io.openmessaging.message.Message message)
List<io.openmessaging.producer.SendResult> send(List<io.openmessaging.message.Message> messages)
Copyright © 2020 Joyqueue Community. All rights reserved.