This is an automated email from the ASF dual-hosted git repository.
zhanglei pushed a change to branch SCB-1321
in repository https://gitbox.apache.org/repos/asf/servicecomb-pack.git.
from 9cee529 SCB-1321 Support Akka Persistent Redis Recovery
new f59e348 SCB-1321 Add SagaActor call compensate
new 0ed1b15 SCB-1321 Add GrpcSagaEventService for SagaActor Events
The 2 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:
alpha/alpha-fsm/pom.xml | 4 +
.../pack/alpha/fsm/FsmAutoConfiguration.java | 3 +
.../servicecomb/pack/alpha/fsm/SagaActor.java | 62 +++++---
.../apache/servicecomb/pack/alpha/fsm/TxState.java | 2 +-
.../pack/alpha/fsm/domain/AddTxEventDomain.java | 42 +++++-
...mponsitedEvent.java => TxCompensatedEvent.java} | 16 +-
.../pack/alpha/fsm/event/TxStartedEvent.java | 103 +++++++++++++
.../pack/alpha/fsm/event/base/TxEvent.java | 18 +++
.../fsm/event/consumer/SagaEventConsumer.java | 5 +-
.../servicecomb/pack/alpha/fsm/model/TxEntity.java | 70 +++++++++
.../fsm/spring/integration/akka/LogExtension.java | 31 ----
...ogExtensionImpl.java => SagaDataExtension.java} | 25 +++-
.../integration/akka/SpringAkkaExtension.java | 77 ++++++++++
.../servicecomb/pack/alpha/fsm/SagaActorTest.java | 32 ++--
.../pack/alpha/fsm/SagaEventSender.java | 50 +++----
.../pack/alpha/fsm/SagaIntegrationTest.java | 26 ++--
alpha/alpha-server/pom.xml | 16 ++
.../servicecomb/pack/alpha/server/AlphaConfig.java | 21 +++
.../alpha/server/{ => fsm}/GrpcOmegaCallback.java | 11 +-
.../alpha/server/fsm/GrpcSagaEventService.java | 130 ++++++++++++++++
.../src/main/resources/application.yaml | 9 ++
.../alpha/server/fsm/AlphaIntegrationFsmTest.java | 134 +++++++++++++++++
.../alpha/server/fsm/OmegaEventSagaSimulator.java | 159 ++++++++++++++++++++
.../pack/alpha/server/fsm/OmegaEventSender.java | 163 +++++++++++++++++++++
.../src/test/resources/log4j2.xml | 0
.../apache/servicecomb/pack/common/EventType.java | 3 +-
pom.xml | 5 +
27 files changed, 1087 insertions(+), 130 deletions(-)
rename
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/event/{TxComponsitedEvent.java
=> TxCompensatedEvent.java} (77%)
delete mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/spring/integration/akka/LogExtension.java
rename
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/spring/integration/akka/{LogExtensionImpl.java
=> SagaDataExtension.java} (56%)
create mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/spring/integration/akka/SpringAkkaExtension.java
copy
alpha/alpha-server/src/main/java/org/apache/servicecomb/pack/alpha/server/{ =>
fsm}/GrpcOmegaCallback.java (96%)
create mode 100644
alpha/alpha-server/src/main/java/org/apache/servicecomb/pack/alpha/server/fsm/GrpcSagaEventService.java
create mode 100644
alpha/alpha-server/src/test/java/org/apache/servicecomb/pack/alpha/server/fsm/AlphaIntegrationFsmTest.java
create mode 100644
alpha/alpha-server/src/test/java/org/apache/servicecomb/pack/alpha/server/fsm/OmegaEventSagaSimulator.java
create mode 100644
alpha/alpha-server/src/test/java/org/apache/servicecomb/pack/alpha/server/fsm/OmegaEventSender.java
copy alpha/{alpha-fsm => alpha-server}/src/test/resources/log4j2.xml (100%)
