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/servicecomb-pack.git.
from 6d5bef9 SagaStartAnnotationProcessorTimeoutWrapper handle the
autoClose is false case
new a68d398 SCB-1368 Add akka cluster dependency
new 711eebc SCB-1368 Add akka cluster property adapter
new bfe4e11 SCB-1368 Allows the use of system variables
-Dlog-file-name=xxxx.log to define log file name
new 001a26d SCB-1368 Refactoring model alpha-fsm-channel-kafka and
alpha-fsm-channel-redis to alpha-fsm
new 55c4a3a SCB-1368 Define generic interface
new 03d86ca SCB-1368 Refactoring memory channel
new 4c2b1e4 SCB-1368 Add Akka cluster dependencies
new 10c54af SCB-1368 Add shard region selection Actor
new 1bd3518 SCB-1368 Add default configuration of Akka cluster
new b5c2d1c SCB-1368 Indicate sub types of serializable polymorphic types
new 0373fa7 SCB-1368 Remove persistent queues for reliability
new 92264de SCB-1368 Fix log information bug
new 93fa5f2 SCB-1368 Add default configuration of Akka
new ae45ed3 SCB-1368 Log4j2 disable the automatic shutdown hook
new df1c109 SCB-1368 static variable name is written in upper case letters
new 94a9287 SCB-1368 Polishing
new f3472e0 SCB-1368 Kafka at-least-once delivery
new 4fd334a SCB-1368 Added debug info
new 2d26788 SCB-1368 Clean up kafka client extra dependencies
new 6779ea1 SCB-1368 Delete the Actor state persistent data after
transaction data is saved successfully
new 5693b81 SCB-1368 Change ShardRegion Actor name to
saga-shard-region-actor
new 6e409c2 SCB-1368 Added debug info
new 2639a13 SCB-1368 Ignore akka distributed data local directory
new 235032b SCB-1368 Modify ES default batchSize 100
new eff495d SCB-1368 Added the globalTxId prefix for concurrent
new 8ca383f SCB-1368 Optimize log information
new b5bb417 SCB-1368 Added parameter description
new c0224c1 SCB-1368 Added serialVersionUID
new 72c2ed6 SCB-1368 Ensure message delivery reliability between Kafka
and ClusterShardRegion in cluster mode
new 142ba86 SCB-1368 Optimize log information
new b1d919d SCB-1368 The default value of commit-time-warning is changed
to 5s
new 24fd1bf SCB-1368 Updated document
new bf2b577 SCB-1368 Use dependency management to define the Kafka version
new d91304a SCB-1368 Update test cases for Akka Cluster Sharding
new 814d2bb SCB-1368 Update test cases timeout for CI
new af32706 SCB-1368 Delete useless code
new b689c07 SCB-1368 Fix metric statistics bug
new e37775a SCB-1368 Added the license header.
new 828908e SCB-1368 disable JMX over HTTP
new 80fb4b6 SCB-1368 Fix metric statistics bug
new ddecff7 SCB-1368 Update test cases timeout for CI
new ed6fa9d SCB-1368 Added null protection logic
The 42 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:
.gitignore | 3 +
.../org/apache/servicecomb/pack/PackStepdefs.java | 2 +-
.../pack/alpha/benchmark/SagaEventBenchmark.java | 34 +-
.../alpha/core/fsm/channel/MessagePublisher.java | 4 +-
.../pack/alpha/core/fsm/event/base/BaseEvent.java | 41 +-
.../pack/alpha/core/metrics/MetricsBean.java | 7 +-
.../pack/alpha/core/metrics/MetricsBeanTest.java | 74 +++
alpha/alpha-fsm-channel-kafka/README.md | 28 --
alpha/alpha-fsm-channel-kafka/pom.xml | 113 -----
.../kafka/KafkaChannelAutoConfiguration.java | 175 -------
.../fsm/channel/kafka/KafkaMessageListener.java | 49 --
.../src/main/resources/META-INF/spring.factories | 17 -
.../channel/kafka/test/KafkaActorEventSink.java | 31 --
.../fsm/channel/kafka/test/KafkaApplication.java | 40 --
.../fsm/channel/kafka/test/KafkaChannelTest.java | 95 ----
.../src/test/resources/log4j2.xml | 30 --
alpha/alpha-fsm-channel-redis/README.md | 17 -
alpha/alpha-fsm-channel-redis/pom.xml | 99 ----
.../src/main/resources/META-INF/spring.factories | 17 -
.../pack/alpha/fsm/RedisChannelTest.java | 130 -----
.../servicecomb/pack/alpha/fsm/RedisEventSink.java | 32 --
.../src/test/resources/log4j2.xml | 30 --
alpha/alpha-fsm/pom.xml | 53 ++-
.../pack/alpha/fsm/FsmAutoConfiguration.java | 78 +--
.../servicecomb/pack/alpha/fsm/SagaActor.java | 287 ++++++-----
.../pack/alpha/fsm/SagaShardRegionActor.java | 97 ++++
.../fsm/channel/AbstractActorEventChannel.java | 3 -
.../alpha/fsm/channel/AbstractEventConsumer.java | 20 +
.../{ => kafka}/KafkaActorEventChannel.java | 14 +-
.../kafka/KafkaChannelAutoConfiguration.java | 150 ++++++
.../fsm/channel/kafka/KafkaMessagePublisher.java | 22 +-
.../fsm/channel/kafka/KafkaSagaEventConsumer.java | 107 +++++
.../{ => memory}/MemoryActorEventChannel.java | 33 +-
.../memory/MemoryChannelAutoConfiguration.java | 62 +++
.../MemorySagaEventConsumer.java} | 48 +-
.../alpha/fsm/channel/redis/MessageSerializer.java | 27 +-
.../{ => redis}/RedisActorEventChannel.java | 18 +-
.../redis/RedisChannelAutoConfiguration.java | 49 +-
.../fsm/channel/redis/RedisMessagePublisher.java | 15 +-
.../fsm/channel/redis/RedisSagaEventConsumer.java} | 50 +-
.../DefaultTransactionRepositoryChannel.java} | 30 +-
.../MemoryTransactionRepositoryChannel.java | 71 ---
.../ElasticsearchTransactionRepository.java | 8 +-
.../pack/alpha/fsm/sink/SagaActorEventSender.java | 82 ----
.../integration/akka/AkkaClusterListener.java | 80 ++++
.../akka/AkkaConfigPropertyAdapter.java | 26 +-
.../servicecomb/pack/alpha/fsm/SagaActorTest.java | 7 +-
.../pack/alpha/fsm/SagaIntegrationTest.java | 60 +--
.../alpha-fsm/src/test/resources/application.yaml | 205 ++++++++
alpha/alpha-server/pom.xml | 4 +
.../alpha/server/fsm/FsmSagaDataController.java | 19 +-
.../src/main/resources/application.yaml | 112 ++++-
alpha/alpha-server/src/main/resources/log4j2.xml | 9 +-
alpha/pom.xml | 2 -
docs/fsm/akka_zh.md | 69 +++
docs/fsm/apis_zh.md | 132 ++++++
docs/fsm/assets/alpha-cluster-architecture.png | Bin 0 -> 537656 bytes
docs/fsm/eventchannel_zh.md | 34 ++
docs/fsm/fsm_manual.md | 300 ++++++++++++
docs/fsm/fsm_manual_zh.md | 199 +++++---
docs/fsm/how_to_use_fsm.md | 522 --------------------
docs/fsm/how_to_use_fsm_zh.md | 527 ---------------------
docs/fsm/persistence_zh.md | 235 +++++++++
docs/user_guide.md | 2 +-
docs/user_guide_zh.md | 2 +-
pom.xml | 44 ++
66 files changed, 2363 insertions(+), 2619 deletions(-)
create mode 100644
alpha/alpha-core/src/test/java/org/apache/servicecomb/pack/alpha/core/metrics/MetricsBeanTest.java
delete mode 100644 alpha/alpha-fsm-channel-kafka/README.md
delete mode 100644 alpha/alpha-fsm-channel-kafka/pom.xml
delete mode 100644
alpha/alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaChannelAutoConfiguration.java
delete mode 100644
alpha/alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaMessageListener.java
delete mode 100644
alpha/alpha-fsm-channel-kafka/src/main/resources/META-INF/spring.factories
delete mode 100644
alpha/alpha-fsm-channel-kafka/src/test/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/test/KafkaActorEventSink.java
delete mode 100644
alpha/alpha-fsm-channel-kafka/src/test/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/test/KafkaApplication.java
delete mode 100644
alpha/alpha-fsm-channel-kafka/src/test/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/test/KafkaChannelTest.java
delete mode 100644 alpha/alpha-fsm-channel-kafka/src/test/resources/log4j2.xml
delete mode 100644 alpha/alpha-fsm-channel-redis/README.md
delete mode 100644 alpha/alpha-fsm-channel-redis/pom.xml
delete mode 100644
alpha/alpha-fsm-channel-redis/src/main/resources/META-INF/spring.factories
delete mode 100644
alpha/alpha-fsm-channel-redis/src/test/java/org/apache/servicecomb/pack/alpha/fsm/RedisChannelTest.java
delete mode 100644
alpha/alpha-fsm-channel-redis/src/test/java/org/apache/servicecomb/pack/alpha/fsm/RedisEventSink.java
delete mode 100644 alpha/alpha-fsm-channel-redis/src/test/resources/log4j2.xml
create mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/SagaShardRegionActor.java
create mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/AbstractEventConsumer.java
rename
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/{
=> kafka}/KafkaActorEventChannel.java (67%)
create mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaChannelAutoConfiguration.java
rename alpha/{alpha-fsm-channel-kafka =>
alpha-fsm}/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaMessagePublisher.java
(70%)
create mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaSagaEventConsumer.java
copy
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/{
=> memory}/MemoryActorEventChannel.java (70%)
create mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/memory/MemoryChannelAutoConfiguration.java
rename
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/{MemoryActorEventChannel.java
=> memory/MemorySagaEventConsumer.java} (53%)
rename alpha/{alpha-fsm-channel-redis =>
alpha-fsm}/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/redis/MessageSerializer.java
(84%)
rename
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/{
=> redis}/RedisActorEventChannel.java (75%)
rename alpha/{alpha-fsm-channel-redis =>
alpha-fsm}/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/redis/RedisChannelAutoConfiguration.java
(69%)
rename alpha/{alpha-fsm-channel-redis =>
alpha-fsm}/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/redis/RedisMessagePublisher.java
(75%)
rename
alpha/{alpha-fsm-channel-redis/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/redis/RedisMessageSubscriber.java
=>
alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/redis/RedisSagaEventConsumer.java}
(54%)
rename
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/{channel/ActiveMQActorEventChannel.java
=> repository/channel/DefaultTransactionRepositoryChannel.java} (54%)
delete mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/repository/channel/MemoryTransactionRepositoryChannel.java
delete mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/sink/SagaActorEventSender.java
create mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/spring/integration/akka/AkkaClusterListener.java
create mode 100644 alpha/alpha-fsm/src/test/resources/application.yaml
create mode 100644 docs/fsm/akka_zh.md
create mode 100644 docs/fsm/apis_zh.md
create mode 100644 docs/fsm/assets/alpha-cluster-architecture.png
create mode 100644 docs/fsm/eventchannel_zh.md
create mode 100755 docs/fsm/fsm_manual.md
delete mode 100644 docs/fsm/how_to_use_fsm.md
delete mode 100644 docs/fsm/how_to_use_fsm_zh.md
create mode 100644 docs/fsm/persistence_zh.md
