You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicecomb.apache.org by ni...@apache.org on 2018/08/28 06:40:28 UTC
[incubator-servicecomb-saga] 14/14: SCB-856 Revise alpha TCC server
test case.
This is an automated email from the ASF dual-hosted git repository.
ningjiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git
commit 697dcc30906f675d1b669e1b2af07cb6dedc8d74
Author: cherrylzhao <zh...@126.com>
AuthorDate: Tue Aug 28 11:54:14 2018 +0800
SCB-856 Revise alpha TCC server test case.
---
.../apache/servicecomb/saga/alpha/tcc/server/AlphaTccServerTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/alpha/alpha-server/src/test/java/org/apache/servicecomb/saga/alpha/tcc/server/AlphaTccServerTest.java b/alpha/alpha-server/src/test/java/org/apache/servicecomb/saga/alpha/tcc/server/AlphaTccServerTest.java
index 4bbfa45..a5030b1 100644
--- a/alpha/alpha-server/src/test/java/org/apache/servicecomb/saga/alpha/tcc/server/AlphaTccServerTest.java
+++ b/alpha/alpha-server/src/test/java/org/apache/servicecomb/saga/alpha/tcc/server/AlphaTccServerTest.java
@@ -70,7 +70,7 @@ public class AlphaTccServerTest {
private final Queue<GrpcTccCoordinateCommand> receivedCommands = new ConcurrentLinkedQueue<>();
private final TccCoordinateCommandStreamObserver commandStreamObserver =
- new TccCoordinateCommandStreamObserver(this::onCompensation, receivedCommands);
+ new TccCoordinateCommandStreamObserver(this::onReceivedCoordinateCommand, receivedCommands);
private final String globalTxId = UUID.randomUUID().toString();
private final String localTxId = UUID.randomUUID().toString();
@@ -256,7 +256,7 @@ public class AlphaTccServerTest {
.build();
}
- private GrpcAck onCompensation(GrpcTccCoordinateCommand command) {
+ private GrpcAck onReceivedCoordinateCommand(GrpcTccCoordinateCommand command) {
return GrpcAck.newBuilder().setAborted(false).build();
}