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/incubator-servicecomb-saga.git.
from aff2719 SCB-505 Update to throw exception when the transaction timeout
new bd5ed77 SCB-224: alpha support retries
new 0651b91 SCB-224: omega support retries
new f75e0b9 SCB-224 alpha support retries event
new 2357d13 SCB-224 omega support retries event
new 9d2a0b8 SCB-224 alpha:support retries use command
new 7e01a4f SCB-224 retry synchronously
new ce71ab7 SCB-224 resolved rebase conflicts
The 7 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/saga/PackStepdefs.java | 16 +--
.../servicecomb/saga/alpha/core/Command.java | 6 +-
.../servicecomb/saga/alpha/core/EventScanner.java | 22 ++--
.../saga/alpha/core/PushBackOmegaCallback.java | 9 +-
.../saga/alpha/core/TxConsistentService.java | 16 +--
.../servicecomb/saga/alpha/core/TxEvent.java | 35 +++++-
.../saga/alpha/core/TxEventRepository.java | 2 +-
.../saga/alpha/core/TxConsistentServiceTest.java | 17 ++-
.../saga/alpha/server/CommandEntityRepository.java | 15 ++-
.../saga/alpha/server/GrpcOmegaCallback.java | 2 +-
.../saga/alpha/server/GrpcTxEventEndpointImpl.java | 2 +
.../saga/alpha/server/SpringCommandRepository.java | 9 +-
.../saga/alpha/server/SpringTxEventRepository.java | 15 +--
.../alpha/server/SpringTxTimeoutRepository.java | 5 +-
.../alpha/server/TxEventEnvelopeRepository.java | 48 +++++---
.../src/main/resources/schema-mysql.sql | 3 +
.../src/main/resources/schema-postgresql.sql | 2 +
.../saga/alpha/server/AlphaIntegrationTest.java | 80 ++++++++++----
alpha/alpha-server/src/test/resources/schema.sql | 2 +
.../pack/tests/CommandEnvelopeRepository.java | 8 +-
.../integration/pack/tests/GreetingController.java | 8 ++
.../integration/pack/tests/GreetingService.java | 22 ++++
.../saga/integration/pack/tests/PackIT.java | 92 ++++++++++++++--
.../connector/grpc/GrpcClientMessageSender.java | 7 +-
.../grpc/GrpcCompensateStreamObserver.java | 6 +-
.../grpc/LoadBalancedClusterMessageSender.java | 8 +-
.../connector/grpc/PushBackReconnectRunnable.java | 8 +-
.../grpc/LoadBalancedClusterMessageSenderTest.java | 15 ++-
.../connector/grpc/RetryableMessageSenderTest.java | 3 +-
.../saga/omega/context/CompensationContext.java | 6 +-
.../spring/CompensableAnnotationProcessor.java | 1 +
.../spring/CompensableMethodCheckingCallback.java | 11 +-
.../spring/TransactionAspectConfig.java | 5 +-
.../spring/TransactionInterceptionTest.java | 102 ++++++++++++++---
.../spring/TransactionalUserService.java | 24 +++-
.../saga/omega/transaction/spring/User.java | 2 +-
.../omega/transaction/CompensableInterceptor.java | 10 +-
.../transaction/CompensationMessageHandler.java | 6 +-
...TransactionAspect.java => DefaultRecovery.java} | 56 +++++-----
.../omega/transaction/EventAwareInterceptor.java | 6 +-
.../saga/omega/transaction/ForwardRecovery.java | 76 +++++++++++++
.../saga/omega/transaction/RecoveryPolicy.java} | 18 ++-
...phaResponse.java => RecoveryPolicyFactory.java} | 19 ++--
.../saga/omega/transaction/SagaEndedEvent.java | 5 +-
.../transaction/SagaStartAnnotationProcessor.java | 3 +-
.../saga/omega/transaction/SagaStartAspect.java | 2 +-
.../saga/omega/transaction/SagaStartedEvent.java | 2 +-
.../saga/omega/transaction/TransactionAspect.java | 33 +-----
.../saga/omega/transaction/TxAbortedEvent.java | 3 +-
.../saga/omega/transaction/TxCompensatedEvent.java | 2 +-
.../saga/omega/transaction/TxEndedEvent.java | 2 +-
.../saga/omega/transaction/TxEvent.java | 23 +++-
.../saga/omega/transaction/TxStartedEvent.java | 7 +-
.../omega/transaction/annotations/Compensable.java | 8 +-
.../transaction/CompensableInterceptorTest.java | 8 +-
.../CompensationMessageHandlerTest.java | 12 +-
...ionAspectTest.java => DefaultRecoveryTest.java} | 115 ++++++++++++-------
...ionAspectTest.java => ForwardRecoveryTest.java} | 122 ++++++++++++---------
.../SagaStartAnnotationProcessorTest.java | 4 +-
.../omega/transaction/TransactionAspectTest.java | 92 +++++++++++++---
.../src/main/proto/GrpcTxEvent.proto | 13 ++-
61 files changed, 898 insertions(+), 383 deletions(-)
copy
omega/omega-spring-tx/src/test/java/org/apache/servicecomb/saga/omega/transaction/spring/UserRepository.java
=>
integration-tests/pack-tests/src/test/java/org/apache/servicecomb/saga/integration/pack/tests/CommandEnvelopeRepository.java
(77%)
copy
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/{TransactionAspect.java
=> DefaultRecovery.java} (56%)
create mode 100644
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/ForwardRecovery.java
copy
omega/{omega-spring-tx/src/test/java/org/apache/servicecomb/saga/omega/transaction/spring/MisconfiguredService.java
=>
omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/RecoveryPolicy.java}
(65%)
copy
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/{AlphaResponse.java
=> RecoveryPolicyFactory.java} (56%)
copy
omega/omega-transaction/src/test/java/org/apache/servicecomb/saga/omega/transaction/{TransactionAspectTest.java
=> DefaultRecoveryTest.java} (55%)
copy
omega/omega-transaction/src/test/java/org/apache/servicecomb/saga/omega/transaction/{TransactionAspectTest.java
=> ForwardRecoveryTest.java} (61%)
--
To stop receiving notification emails like this one, please contact
ningji...@apache.org.
