diff --git a/examples/pom.xml b/examples/pom.xml
index af10e1d15ab37..7f56445f2edf1 100644
--- a/examples/pom.xml
+++ b/examples/pom.xml
@@ -60,7 +60,7 @@
3.2.1.Final
2.1.3
- 1.4.2
+ 1.6.1
4.13.2
1.3
diff --git a/kernel/transaction/type/base/seata-at/pom.xml b/kernel/transaction/type/base/seata-at/pom.xml
index 897e77130d41d..79f10a03bd1c9 100644
--- a/kernel/transaction/type/base/seata-at/pom.xml
+++ b/kernel/transaction/type/base/seata-at/pom.xml
@@ -28,7 +28,7 @@
${project.artifactId}
- 1.4.2
+ 1.6.1
@@ -51,5 +51,11 @@
${seata.version}
provided
+
+
+ com.fasterxml.jackson.core
+ jackson-databind
+ test
+
diff --git a/kernel/transaction/type/base/seata-at/src/test/java/org/apache/shardingsphere/transaction/base/seata/at/fixture/MockMessageHandler.java b/kernel/transaction/type/base/seata-at/src/test/java/org/apache/shardingsphere/transaction/base/seata/at/fixture/MockMessageHandler.java
index 7e8fe3576cd32..e1baff1870603 100644
--- a/kernel/transaction/type/base/seata-at/src/test/java/org/apache/shardingsphere/transaction/base/seata/at/fixture/MockMessageHandler.java
+++ b/kernel/transaction/type/base/seata-at/src/test/java/org/apache/shardingsphere/transaction/base/seata/at/fixture/MockMessageHandler.java
@@ -88,6 +88,21 @@ public void channelRead(final ChannelHandlerContext ctx, final Object msg) {
response.setBody(HeartbeatMessage.PONG);
} else if (requestBody instanceof MergedWarpMessage) {
setMergeResultMessage(request, response);
+ } else if (requestBody instanceof GlobalBeginRequest) {
+ GlobalBeginResponse globalBeginResponse = new GlobalBeginResponse();
+ globalBeginResponse.setXid(XID.generateXID(id.incrementAndGet()));
+ globalBeginResponse.setResultCode(ResultCode.Success);
+ response.setBody(globalBeginResponse);
+ } else if (requestBody instanceof GlobalCommitRequest) {
+ GlobalCommitResponse globalCommitResponse = new GlobalCommitResponse();
+ globalCommitResponse.setResultCode(ResultCode.Success);
+ globalCommitResponse.setGlobalStatus(GlobalStatus.Committing);
+ response.setBody(globalCommitResponse);
+ } else if (requestBody instanceof GlobalRollbackRequest) {
+ GlobalRollbackResponse globalRollbackResponse = new GlobalRollbackResponse();
+ globalRollbackResponse.setResultCode(ResultCode.Success);
+ globalRollbackResponse.setGlobalStatus(GlobalStatus.Rollbacked);
+ response.setBody(globalRollbackResponse);
}
if (requestBody != HeartbeatMessage.PING) {
requestQueue.offer(requestBody);