| 限定符和类型 | 方法和说明 |
|---|---|
static TxFeedbackConfig |
KeyValueConverter.convertFeedbackConfig(io.openmessaging.KeyValue attributes) |
static TxFeedbackConfig |
KeyValueConverter.convertFeedbackConfig(NameServerConfig nameServerConfig,
io.openmessaging.KeyValue attributes) |
| 构造器和说明 |
|---|
TransactionProducerImpl(ExtensionProducer delegate,
io.openmessaging.producer.TransactionStateCheckListener transactionStateCheckListener,
MessageProducer messageProducer,
MessageAccessPoint messageAccessPoint,
TxFeedbackConfig txFeedbackConfig) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
MessageAccessPoint.setTransactionCallback(String topic,
TxFeedbackConfig config,
TxFeedbackCallback callback) |
| 限定符和类型 | 方法和说明 |
|---|---|
static TxFeedbackManager |
TxFeedbackManagerFactory.create(TxFeedbackConfig config,
NameServerConfig nameServerConfig) |
static TxFeedbackManager |
TxFeedbackManagerFactory.create(TxFeedbackConfig config,
NameServerConfig nameServerConfig,
ClusterManager clusterManager) |
static TxFeedbackManager |
TxFeedbackManagerFactory.create(TxFeedbackConfig config,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
ProducerClientManager producerClientManager) |
static TxFeedbackManager |
TxFeedbackManagerFactory.create(TxFeedbackConfig config,
NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
static TxFeedbackManager |
TxFeedbackManagerFactory.create(TxFeedbackConfig config,
NameServerConfig nameServerConfig,
TransportConfig transportConfig,
ClusterManager clusterManager) |
| 构造器和说明 |
|---|
DefaultTxFeedbackManager(TxFeedbackConfig config,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
MessageSender messageSender) |
TxFeedbackDispatcher(TxFeedbackConfig config,
String topic,
TxFeedbackCallback txFeedbackCallback,
MessageSender messageSender,
ClusterManager clusterManager) |
TxFeedbackScheduler(TxFeedbackConfig config,
String topic,
TxFeedbackCallback txFeedbackCallback,
MessageSender messageSender,
ClusterManager clusterManager) |
| 限定符和类型 | 方法和说明 |
|---|---|
TxFeedbackConfig |
TxFeedbackConfig.copy() |
| 限定符和类型 | 方法和说明 |
|---|---|
static void |
TxFeedbackConfigChecker.check(TxFeedbackConfig config) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected TxFeedbackManager |
DefaultMessageAccessPoint.getTxFeedbackManager(TxFeedbackConfig config) |
void |
DefaultMessageAccessPoint.setTransactionCallback(String topic,
TxFeedbackConfig config,
TxFeedbackCallback callback) |
Copyright © 2020 Joyqueue Community. All rights reserved.