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 281e34c SCB-1321 Add Saga Event Message Bus
new 6ba7899 SCB-1321 Support for defining Akka properties in
application.yaml
new 9cee529 SCB-1321 Support Akka Persistent Redis Recovery
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/README.md | 1 +
alpha/alpha-fsm/pom.xml | 19 +-
.../pack/alpha/fsm/FsmAutoConfiguration.java | 13 +-
.../servicecomb/pack/alpha/fsm/SagaActor.java | 284 ++++++++++++--------
.../apache/servicecomb/pack/alpha/fsm/TxState.java | 3 +-
.../TxEvent.java => domain/AddTxEventDomain.java} | 25 +-
.../pack/alpha/fsm/domain/DomainEvent.java | 5 +-
.../pack/alpha/fsm/domain/SagaEndedDomain.java | 19 +-
.../SagaStartedDomain.java} | 28 +-
.../UpdateTxEventDomain.java} | 26 +-
.../pack/alpha/fsm/event/SagaDomainEvent.java | 31 ---
...t.java => TxComponsitedCheckInternalEvent.java} | 17 +-
.../pack/alpha/fsm/event/base/BaseEvent.java | 5 +
.../akka/AkkaConfigPropertyAdapter.java | 68 +++++
.../servicecomb/pack/alpha/fsm/SagaActorTest.java | 288 +++++++++++++++++++--
.../pack/alpha/fsm/SagaEventSender.java | 60 ++++-
.../pack/alpha/fsm/SagaIntegrationTest.java | 51 +++-
.../alpha-fsm/src/test/resources/application.conf | 20 --
.../alpha-fsm/src/test}/resources/application.yaml | 40 ++-
docs/fsm/assets/saga_state_diagram.png | Bin 237463 -> 244645 bytes
docs/fsm/plantuml/saga-state-diagram.puml | 2 +-
21 files changed, 740 insertions(+), 265 deletions(-)
copy
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/{event/base/TxEvent.java
=> domain/AddTxEventDomain.java} (71%)
copy
omega/omega-context/src/main/java/org/apache/servicecomb/pack/omega/context/IdGenerator.java
=>
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/domain/DomainEvent.java
(87%)
copy
omega/omega-transaction/src/main/java/org/apache/servicecomb/pack/omega/transaction/OmegaException.java
=>
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/domain/SagaEndedDomain.java
(71%)
copy
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/{event/base/BaseEvent.java
=> domain/SagaStartedDomain.java} (65%)
copy
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/{event/base/TxEvent.java
=> domain/UpdateTxEventDomain.java} (70%)
delete mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/event/SagaDomainEvent.java
copy
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/event/{SagaEndedEvent.java
=> TxComponsitedCheckInternalEvent.java} (72%)
create mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/spring/integration/akka/AkkaConfigPropertyAdapter.java
delete mode 100644 alpha/alpha-fsm/src/test/resources/application.conf
copy {demo/saga-dubbo-demo/serviceb/src/main =>
alpha/alpha-fsm/src/test}/resources/application.yaml (60%)