Skip to content

Commit 433c549

Browse files
committed
tx:clean
1 parent 0ac650a commit 433c549

3 files changed

Lines changed: 6 additions & 4 deletions

File tree

example/spring-demo-client/src/main/java/com/codingapi/example/client/TransactionConfiguration.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,9 @@
1919
*
2020
* @author ujued
2121
*/
22-
@Configuration
23-
@EnableTransactionManagement
24-
@EnableConfigurationProperties(TransactionProperties.class)
22+
//@Configuration
23+
//@EnableTransactionManagement
24+
//@EnableConfigurationProperties(TransactionProperties.class)
2525
public class TransactionConfiguration {
2626

2727
@Bean

example/spring-demo-client/src/main/java/com/codingapi/example/client/service/DemoServiceImpl.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
import com.codingapi.example.common.spring.DDemoClient;
66
import com.codingapi.example.common.spring.EDemoClient;
77
import com.codingapi.tx.client.bean.DTXLocal;
8+
import com.codingapi.tx.commons.annotation.LcnTransaction;
89
import org.springframework.beans.factory.annotation.Autowired;
910
import org.springframework.beans.factory.annotation.Value;
1011
import org.springframework.core.annotation.Order;
@@ -35,6 +36,7 @@ public class DemoServiceImpl implements DemoService {
3536
private String appName;
3637

3738
@Override
39+
@LcnTransaction
3840
public String execute(String value) {
3941
String dResp = dDemoClient.rpc(value);
4042
String eResp = eDemoClient.rpc(value);

tx-client/src/main/java/com/codingapi/tx/client/support/separate/CustomizableTransactionSeparator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ public TXLCNTransactionState loadTransactionState(TxTransactionInfo txTransactio
2626
// 发起分布式事务条件
2727
if (txTransactionInfo.isTransactionStart()) {
2828
// 发起方时,对于只加入DTX的事务单元走默认处理
29-
if (txTransactionInfo.getPropagation().equals(DTXPropagation.SUPPORTS)) {
29+
if (DTXPropagation.SUPPORTS.equals(txTransactionInfo.getPropagation())) {
3030
return TXLCNTransactionState.NON;
3131
}
3232
return TXLCNTransactionState.STARTING;

0 commit comments

Comments
 (0)