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 fc3725e SCB-1321 Fix test case sometimes throws an interrupt
exception with CI
new fd538f1 SCB-1321 Car service add exception rules for test
new 4f49d17 SCB-1321 SagaActor Refactoring
new a92bcc5 SCB-1321 Rename akka enabled parameter
alpha.model.actor.enabled to alpha.feature.akka.enabled
new c4c696d SCB-1321 Add message receiving service for the state machine
new 5404aee SCB-1321 Add Akka persistence default parameters
new 2e5e756 SCB-1321 Add Akka support parameters in OmegaContext
new ea7c70a SCB-1321 Refactoring interrupt Omega timeout thread
new e1024e0 SCB-1321 Add acceptance-pack-akka-spring
new c0c6016 SCB-1321 Disable integration-tests module
new f32ffba SCB-1321 Update README.md for Saga State Machine Module
The 10 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:
.../pom.xml | 8 +-
.../org/apache/servicecomb/pack/PackStepdefs.java | 0
.../org/apache/servicecomb/pack/RunCucumberIT.java | 0
.../booking_exception_after_post_car.btm} | 0
.../booking_exception_after_post_hotel.btm} | 2 +-
.../src/test/resources/booking_timeout.btm | 0
.../src/test/resources/log4j2-test.xml | 0
...on_after_post_car_compensated_scenario.feature} | 7 +-
..._after_post_hotel_compensated_scenario.feature} | 11 +-
...ack_booking_timeout_suspended_scenario.feature} | 8 +-
...k_booking_timeout_suspended_scenario.feature 2} | 8 +-
.../pack_car_fail_compensated_scenario.feature} | 13 +-
.../pack_hotel_fail_compensated_scenario.feature} | 3 +-
.../test/resources/pack_success_scenario.feature | 2 +-
acceptance-tests/pom.xml | 3 +-
.../pack/alpha/core/fsm/PackSagaEvent.java | 150 +++++++++++
alpha/alpha-fsm/README.md | 62 ++++-
.../pack/alpha/fsm/FsmAutoConfiguration.java | 2 +-
.../servicecomb/pack/alpha/fsm/SagaActor.java | 130 ++++------
.../pack/alpha/fsm/domain/AddTxEventDomain.java | 61 +----
.../pack/alpha/fsm/domain/DomainEvent.java | 3 +-
.../pack/alpha/fsm/domain/SagaEndedDomain.java | 12 +-
.../pack/alpha/fsm/domain/SagaStartedDomain.java | 35 +--
.../pack/alpha/fsm/domain/UpdateTxEventDomain.java | 36 ++-
.../pack/alpha/fsm/event/SagaAbortedEvent.java | 16 ++
.../pack/alpha/fsm/event/SagaEndedEvent.java | 18 ++
.../pack/alpha/fsm/event/SagaStartedEvent.java | 25 ++
.../pack/alpha/fsm/event/SagaTimeoutEvent.java | 16 ++
.../pack/alpha/fsm/event/TxAbortedEvent.java | 11 +
.../pack/alpha/fsm/event/TxCompensatedEvent.java | 11 +
.../pack/alpha/fsm/event/TxEndedEvent.java | 11 +
.../pack/alpha/fsm/event/TxStartedEvent.java | 36 ---
.../pack/alpha/fsm/event/base/BaseEvent.java | 55 ++++-
.../pack/alpha/fsm/event/base/SagaEvent.java | 9 -
.../pack/alpha/fsm/event/base/TxEvent.java | 44 ----
.../fsm/event/consumer/SagaEventConsumer.java | 7 -
.../servicecomb/pack/alpha/fsm/model/SagaData.java | 84 ++++++-
.../spring/integration/akka/SagaDataExtension.java | 13 +-
.../servicecomb/pack/alpha/fsm/SagaActorTest.java | 77 ++++--
.../pack/alpha/fsm/SagaEventSender.java | 218 ++++++++--------
.../pack/alpha/fsm/SagaIntegrationTest.java | 275 +++++++++------------
.../servicecomb/pack/alpha/server/AlphaConfig.java | 8 +-
.../pack/alpha/server/AlphaEventController.java | 2 +
.../FsmSagaDataController.java} | 47 ++--
.../alpha/server/fsm/GrpcSagaEventService.java | 16 +-
.../src/main/resources/application.yaml | 15 +-
.../alpha/server/fsm/AlphaIntegrationFsmTest.java | 237 +++++++++---------
.../pack/demo/booking/BookingController.java | 6 +-
.../pack/demo/car/CarBookingService.java | 3 +
.../pack/omega/context/OmegaContext.java | 12 +
.../pack/omega/spring/OmegaSpringConfig.java | 6 +-
.../omega/transaction/AbstractRecoveryPolicy.java | 5 +-
.../omega/transaction/CompensableInterceptor.java | 2 +-
.../transaction/RecoveryPolicyTimeoutWrapper.java | 226 -----------------
.../{TxAbortedEvent.java => SagaAbortedEvent.java} | 9 +-
.../transaction/SagaStartAnnotationProcessor.java | 22 +-
.../pack/omega/transaction/SagaStartAspect.java | 35 +--
.../wrapper/RecoveryPolicyTimeoutWrapper.java | 222 +++++++++++++++++
...SagaStartAnnotationProcessorTimeoutWrapper.java | 107 ++++++++
.../SagaStartAnnotationProcessorWrapper.java} | 32 +--
.../omega/transaction/wrapper/TimeoutProb.java | 92 +++++++
.../transaction/wrapper/TimeoutProbManager.java | 100 ++++++++
.../omega/transaction/SagaStartAspectTest.java | 44 +++-
pom.xml | 2 +
64 files changed, 1688 insertions(+), 1044 deletions(-)
copy acceptance-tests/{acceptance-pack-spring-demo =>
acceptance-pack-akka-spring-demo}/pom.xml (96%)
copy acceptance-tests/{acceptance-pack-spring-demo =>
acceptance-pack-akka-spring-demo}/src/test/java/org/apache/servicecomb/pack/PackStepdefs.java
(100%)
copy acceptance-tests/{acceptance-pack-tcc-spring-demo =>
acceptance-pack-akka-spring-demo}/src/test/java/org/apache/servicecomb/pack/RunCucumberIT.java
(100%)
copy
acceptance-tests/{acceptance-pack-spring-demo/src/test/resources/booking_exception.btm
=>
acceptance-pack-akka-spring-demo/src/test/resources/booking_exception_after_post_car.btm}
(100%)
copy
acceptance-tests/{acceptance-pack-spring-demo-with-consul/src/test/resources/booking_exception.btm
=>
acceptance-pack-akka-spring-demo/src/test/resources/booking_exception_after_post_hotel.btm}
(98%)
copy acceptance-tests/{acceptance-pack-spring-demo =>
acceptance-pack-akka-spring-demo}/src/test/resources/booking_timeout.btm (100%)
copy {omega/omega-transaction =>
acceptance-tests/acceptance-pack-akka-spring-demo}/src/test/resources/log4j2-test.xml
(100%)
copy
acceptance-tests/{acceptance-pack-spring-demo-with-consul/src/test/resources/pack_post_car_exception_scenario.feature
=>
acceptance-pack-akka-spring-demo/src/test/resources/pack_booking_exception_after_post_car_compensated_scenario.feature}
(86%)
copy
acceptance-tests/{acceptance-pack-spring-demo-with-zookeeper/src/test/resources/pack_post_car_exception_scenario.feature
=>
acceptance-pack-akka-spring-demo/src/test/resources/pack_booking_exception_after_post_hotel_compensated_scenario.feature}
(81%)
copy
acceptance-tests/{acceptance-pack-cluster-spring-demo/src/test/resources/pack_timeout_scenario.feature
=>
acceptance-pack-akka-spring-demo/src/test/resources/pack_booking_timeout_suspended_scenario.feature}
(86%)
copy
acceptance-tests/{acceptance-pack-cluster-spring-demo/src/test/resources/pack_timeout_scenario.feature
=>
acceptance-pack-akka-spring-demo/src/test/resources/pack_booking_timeout_suspended_scenario.feature
2} (86%)
copy
acceptance-tests/{acceptance-pack-spring-demo-with-zookeeper/src/test/resources/pack_compensation_scenario.feature
=>
acceptance-pack-akka-spring-demo/src/test/resources/pack_car_fail_compensated_scenario.feature}
(78%)
copy
acceptance-tests/{acceptance-pack-spring-demo-with-zookeeper/src/test/resources/pack_compensation_scenario.feature
=>
acceptance-pack-akka-spring-demo/src/test/resources/pack_hotel_fail_compensated_scenario.feature}
(95%)
copy acceptance-tests/{acceptance-pack-spring-demo-with-zookeeper =>
acceptance-pack-akka-spring-demo}/src/test/resources/pack_success_scenario.feature
(98%)
create mode 100644
alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/fsm/PackSagaEvent.java
copy
alpha/alpha-server/src/main/java/org/apache/servicecomb/pack/alpha/server/{AlphaEventController.java
=> fsm/FsmSagaDataController.java} (67%)
delete mode 100644
omega/omega-transaction/src/main/java/org/apache/servicecomb/pack/omega/transaction/RecoveryPolicyTimeoutWrapper.java
copy
omega/omega-transaction/src/main/java/org/apache/servicecomb/pack/omega/transaction/{TxAbortedEvent.java
=> SagaAbortedEvent.java} (83%)
create mode 100644
omega/omega-transaction/src/main/java/org/apache/servicecomb/pack/omega/transaction/wrapper/RecoveryPolicyTimeoutWrapper.java
create mode 100644
omega/omega-transaction/src/main/java/org/apache/servicecomb/pack/omega/transaction/wrapper/SagaStartAnnotationProcessorTimeoutWrapper.java
copy
omega/omega-transaction/src/main/java/org/apache/servicecomb/pack/omega/transaction/{SagaStartAspect.java
=> wrapper/SagaStartAnnotationProcessorWrapper.java} (74%)
create mode 100644
omega/omega-transaction/src/main/java/org/apache/servicecomb/pack/omega/transaction/wrapper/TimeoutProb.java
create mode 100644
omega/omega-transaction/src/main/java/org/apache/servicecomb/pack/omega/transaction/wrapper/TimeoutProbManager.java
