This is an automated email from the ASF dual-hosted git repository.
ningjiang pushed a change to branch master
in repository
https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git.
from 1b1e184 SCB-864 add SQL component content into API document
new 236e0a8 SCB-817 Updated the TCC protocol for CoordinatedEvent
new 80be074 SCB-817 Update the omega transactions code
new 68382f2 SCB-818 Implements the TccEventServie of grpc
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
omega/omega-connector/omega-connector-grpc/pom.xml | 6 +-
.../grpc/GrpcCompensateStreamObserver.java | 3 +-
...rver.java => GrpcCoordinateStreamObserver.java} | 37 +--
.../omega/connector/grpc/GrpcTccEventService.java | 156 +++++++++++++
.../connector/grpc/GrpcTccEventServiceTest.java | 260 +++++++++++++++++++++
...tService.java => CoordinateMessageHandler.java} | 30 +--
.../transaction/{ => tcc}/MessageHandler.java | 4 +-
.../omega/transaction/tcc/TccEventService.java | 8 +-
.../tcc/TccStartAnnotationProcessor.java | 6 +-
.../{TccEndedEvent.java => CoordinatedEvent.java} | 28 ++-
.../tcc/CoordinateMessageHandlerTest.java | 109 +++++++++
.../transaction/tcc/TccParticipatorAspectTest.java | 11 +-
.../tcc/TccStartAnnotationProcessorTest.java | 10 +-
.../omega/transaction/tcc/TccStartAspectTest.java | 9 +-
.../src/main/proto/GrpcTccEvent.proto | 12 +
pom.xml | 5 +
16 files changed, 624 insertions(+), 70 deletions(-)
copy
omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/saga/omega/connector/grpc/{GrpcCompensateStreamObserver.java
=> GrpcCoordinateStreamObserver.java} (54%)
create mode 100644
omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/saga/omega/connector/grpc/GrpcTccEventService.java
create mode 100644
omega/omega-connector/omega-connector-grpc/src/test/java/org/apache/servicecomb/saga/omega/connector/grpc/GrpcTccEventServiceTest.java
copy
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/tcc/{TccEventService.java
=> CoordinateMessageHandler.java} (59%)
copy
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/{
=> tcc}/MessageHandler.java (88%)
copy
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/tcc/events/{TccEndedEvent.java
=> CoordinatedEvent.java} (77%)
create mode 100644
omega/omega-transaction/src/test/java/org/apache/servicecomb/saga/omega/transaction/tcc/CoordinateMessageHandlerTest.java