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 9b36a38 SCB-1321 Update document format
new ed4d692 SCB-1321 Modify SagaActor log level to DEBUG
new 0f507d5 SCB-1321 Delete unused methods
new 50698eb SCB-1321 Delete unused methods
new a93055e SCB-1321 Remove Actor replying methods
new 9eaf13b SCB-1321 Optimize termination of SagaData cache for stress
test
new f2ac338 SCB-1321 Optimize Benchmark JVM Parameters
new 07815c2 SCB-1321 Modify RESTful API /saga/events to /saga/events/last
new e19d72f SCB-1321 Modify Scenario Name
new 89f652b SCB-1321 Remove EventBus between gRPC and Akka
new 35887b8 SCB-1321 Ignore onDisconnected error
new fd84324 SCB-1321 Rename RESTful /saga to /saga/akka for acceptance
tests
new ac55eec SCB-1321 Optimize alpha throughput
The 12 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:
.../org/apache/servicecomb/pack/PackStepdefs.java | 4 +-
...ion_after_post_car_compensated_scenario.feature | 2 +-
...n_after_post_hotel_compensated_scenario.feature | 2 +-
...pack_booking_timeout_suspended_scenario.feature | 2 +-
...ck_booking_timeout_suspended_scenario.feature 2 | 44 -------
.../pack_car_fail_compensated_scenario.feature | 2 +-
.../pack_hotel_fail_compensated_scenario.feature | 2 +-
.../pack/alpha/benchmark/Application.java | 6 +-
alpha/alpha-fsm/Benchmark.md | 12 +-
.../pack/alpha/fsm/FsmAutoConfiguration.java | 48 +++++--
.../servicecomb/pack/alpha/fsm/SagaActor.java | 120 ++++++++++--------
.../fsm/channel/ActiveMQActorEventChannel.java | 38 +++---
.../ActorEventChannel.java} | 7 +-
.../alpha/fsm/channel/KafkaActorEventChannel.java | 36 +++---
.../alpha/fsm/channel/MemoryActorEventChannel.java | 70 +++++++++++
.../alpha/fsm/channel/RedisActorEventChannel.java | 38 +++---
.../pack/alpha/fsm/domain/SagaEndedDomain.java | 5 +
.../servicecomb/pack/alpha/fsm/model/SagaData.java | 3 +-
.../DomainEvent.java => sink/ActorEventSink.java} | 8 +-
.../SagaActorEventSender.java} | 63 ++++------
.../spring/integration/akka/SagaDataExtension.java | 72 +++++++++--
.../servicecomb/pack/alpha/fsm/SagaActorTest.java | 140 ++++++++++-----------
.../pack/alpha/fsm/SagaIntegrationTest.java | 65 +++++-----
.../servicecomb/pack/alpha/server/AlphaConfig.java | 7 +-
.../pack/alpha/server/AlphaEventController.java | 1 -
.../alpha/server/fsm/FsmSagaDataController.java | 4 +-
.../alpha/server/fsm/GrpcSagaEventService.java | 10 +-
.../src/main/resources/application.yaml | 6 +
.../alpha/server/fsm/AlphaIntegrationFsmTest.java | 33 ++---
29 files changed, 485 insertions(+), 365 deletions(-)
delete mode 100644
acceptance-tests/acceptance-pack-akka-spring-demo/src/test/resources/pack_booking_timeout_suspended_scenario.feature
2
copy
omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/core/ReconnectStreamObserver.java
=>
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/ActiveMQActorEventChannel.java
(57%)
copy
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/{domain/DomainEvent.java
=> channel/ActorEventChannel.java} (84%)
copy
omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/core/ReconnectStreamObserver.java
=>
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/KafkaActorEventChannel.java
(57%)
create mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/MemoryActorEventChannel.java
copy
omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/core/ReconnectStreamObserver.java
=>
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/RedisActorEventChannel.java
(57%)
copy
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/{domain/DomainEvent.java
=> sink/ActorEventSink.java} (84%)
rename
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/{event/consumer/SagaEventConsumer.java
=> sink/SagaActorEventSender.java} (51%)
