| 程序包 | 说明 |
|---|---|
| io.openmessaging.joyqueue.producer.support | |
| org.joyqueue.client.internal.producer | |
| org.joyqueue.client.internal.producer.support |
| 限定符和类型 | 方法和说明 |
|---|---|
protected TransactionMessageProducer |
TransactionalResultAdapter.prepare(io.openmessaging.message.Message message,
String transactionId,
MessageProducer messageProducer) |
protected TransactionMessageProducer |
ExtensionTransactionalResultAdapter.prepare(String transactionId) |
| 限定符和类型 | 方法和说明 |
|---|---|
TransactionMessageProducer |
MessageProducer.beginTransaction() |
TransactionMessageProducer |
MessageProducer.beginTransaction(long timeout,
TimeUnit timeoutUnit) |
TransactionMessageProducer |
MessageProducer.beginTransaction(String transactionId) |
TransactionMessageProducer |
MessageProducer.beginTransaction(String transactionId,
long timeout,
TimeUnit timeoutUnit) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
DefaultTransactionMessageProducer
DefaultTransactionMessageProducer
author: gaohaoxiang
date: 2018/12/20
|
| 限定符和类型 | 方法和说明 |
|---|---|
TransactionMessageProducer |
MessageProducerWrapper.beginTransaction() |
TransactionMessageProducer |
DefaultMessageProducer.beginTransaction() |
TransactionMessageProducer |
MessageProducerWrapper.beginTransaction(long timeout,
TimeUnit timeoutUnit) |
TransactionMessageProducer |
DefaultMessageProducer.beginTransaction(long timeout,
TimeUnit timeoutUnit) |
TransactionMessageProducer |
MessageProducerWrapper.beginTransaction(String transactionId) |
TransactionMessageProducer |
DefaultMessageProducer.beginTransaction(String transactionId) |
TransactionMessageProducer |
MessageProducerWrapper.beginTransaction(String transactionId,
long timeout,
TimeUnit timeoutUnit) |
TransactionMessageProducer |
DefaultMessageProducer.beginTransaction(String transactionId,
long timeout,
TimeUnit timeoutUnit) |
Copyright © 2020 Joyqueue Community. All rights reserved.