diff --git a/examples/pom.xml b/examples/pom.xml index af10e1d15ab37e..7f56445f2edf1a 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 897e77130d41d6..79f10a03bd1c95 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 7e8fe3576cd323..e1baff18706031 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);