This is an automated email from the ASF dual-hosted git repository.
panjuan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 3e99fb3390f Remove useless code of
NarayanaXATransactionManagerProvider (#25012)
3e99fb3390f is described below
commit 3e99fb3390f001516d23ab16a65277162d0eb60c
Author: Liang Zhang <[email protected]>
AuthorDate: Wed Apr 5 13:31:02 2023 +0800
Remove useless code of NarayanaXATransactionManagerProvider (#25012)
---
.../xa/narayana/manager/NarayanaXATransactionManagerProvider.java | 2 --
1 file changed, 2 deletions(-)
diff --git
a/kernel/transaction/type/xa/provider/narayana/src/main/java/org/apache/shardingsphere/transaction/xa/narayana/manager/NarayanaXATransactionManagerProvider.java
b/kernel/transaction/type/xa/provider/narayana/src/main/java/org/apache/shardingsphere/transaction/xa/narayana/manager/NarayanaXATransactionManagerProvider.java
index dfbf233b80d..e59c7e5728d 100644
---
a/kernel/transaction/type/xa/provider/narayana/src/main/java/org/apache/shardingsphere/transaction/xa/narayana/manager/NarayanaXATransactionManagerProvider.java
+++
b/kernel/transaction/type/xa/provider/narayana/src/main/java/org/apache/shardingsphere/transaction/xa/narayana/manager/NarayanaXATransactionManagerProvider.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.transaction.xa.narayana.manager;
import com.arjuna.ats.arjuna.objectstore.StoreManager;
-import com.arjuna.ats.arjuna.recovery.RecoveryManager;
import com.arjuna.ats.internal.arjuna.recovery.AtomicActionRecoveryModule;
import com.arjuna.ats.internal.jta.recovery.arjunacore.XARecoveryModule;
import com.arjuna.ats.jbossatx.jta.RecoveryManagerService;
@@ -55,7 +54,6 @@ public final class NarayanaXATransactionManagerProvider
implements XATransaction
transactionManager =
jtaPropertyManager.getJTAEnvironmentBean().getTransactionManager();
xaRecoveryModule = XARecoveryModule.getRegisteredXARecoveryModule();
recoveryManagerService = new RecoveryManagerService();
- RecoveryManager.delayRecoveryManagerThread();
recoveryManagerService.create();
recoveryManagerService.start();
}