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();
   }