From 6fc13b2f01d942d0c83cda31b776f07d723c8f5d Mon Sep 17 00:00:00 2001
From: cherrylzhao <zhaojunv3@126.com>
Date: Wed, 13 Mar 2019 16:57:02 +0800
Subject: [PATCH] revise SpringNamespaceExample for XA.

---
 .../namespace/SpringNamespaceExample.java       | 17 ++++++++++++++---
 1 file changed, 14 insertions(+), 3 deletions(-)

diff --git a/sharding-jdbc-example/transaction-example/transaction-2pc-xa-example/transaction-xa-spring-namespace-example/src/main/java/io/shardingsphere/example/transaction/xa/spring/namespace/SpringNamespaceExample.java b/sharding-jdbc-example/transaction-example/transaction-2pc-xa-example/transaction-xa-spring-namespace-example/src/main/java/io/shardingsphere/example/transaction/xa/spring/namespace/SpringNamespaceExample.java
index e3f22c99f1..9110ee2a00 100644
--- a/sharding-jdbc-example/transaction-example/transaction-2pc-xa-example/transaction-xa-spring-namespace-example/src/main/java/io/shardingsphere/example/transaction/xa/spring/namespace/SpringNamespaceExample.java
+++ b/sharding-jdbc-example/transaction-example/transaction-2pc-xa-example/transaction-xa-spring-namespace-example/src/main/java/io/shardingsphere/example/transaction/xa/spring/namespace/SpringNamespaceExample.java
@@ -23,12 +23,23 @@ import org.springframework.context.support.ClassPathXmlApplicationContext;
 public class SpringNamespaceExample {
     
     private static final String CONFIG_FILE = "META-INF/application-sharding-databases-tables.xml";
+//    private static final String CONFIG_FILE = "META-INF/application-master-slave.xml";
     
     public static void main(final String[] args) {
         try (ConfigurableApplicationContext applicationContext = new ClassPathXmlApplicationContext(CONFIG_FILE)) {
-            XATransactionalService transactionalService = applicationContext.getBean(XATransactionalService.class);
-            transactionalService.initEnvironment();
-            transactionalService.processSuccess();
+            processXATransaction(applicationContext);
+        }
+    }
+    
+    private static void processXATransaction(final ConfigurableApplicationContext applicationContext) {
+        XATransactionalService transactionalService = applicationContext.getBean(XATransactionalService.class);
+        transactionalService.initEnvironment();
+        transactionalService.processSuccess();
+        try {
+            transactionalService.processFailure();
+        } catch (final Exception ex) {
+            transactionalService.printData();
+        } finally {
             transactionalService.cleanEnvironment();
         }
     }
-- 
GitLab