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 <[email protected]> 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(); }
