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 2b62bdb SCB-213 remove ended event from map
new 968247f SCB-212 delegated compensation context a dedicated class
new 5b0be4b SCB-212 made each @Compensable as a new sub-transaction
new 137a1f4 SCB-212 removed parent tx id from omega context, since it's
not necessary
new 5212383 SCB-212 united interceptors into one
new 0aaa3fd SCB-212 tx timeout impl
new 5751a11 SCB-212 replaced timeout impl with atomic to avoid locking
new 51b1322 SCB-212 added saga start timeout
new 0a18ed8 SCB-212 removed unnecessary lines
new 5044410 SCB-212 compensated on TxEndedEvent immediately if global TX
already failed, in case of timeout
new 602bff5 SCB-212 attempted to fix random test failure by resetting
latency before test
new 20a5886 SCB-212 better readability
new e5e65b9 SCB-212 closed sender after each test to avoid test
interference
new 05113e5 SCB-212 fixed rebase conflict
new 8c455ad SCB-212 attempted to fix test failure
new 160bade SCB-212 replaced completable future with executor to avoid
test failures in maven
The 15 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:
.../saga/alpha/core/TxConsistentService.java | 31 +++-
.../saga/alpha/core/TxEventRepository.java | 2 +-
.../saga/alpha/core/TxConsistentServiceTest.java | 18 +-
.../saga/alpha/server/SpringTxEventRepository.java | 2 +-
.../saga/alpha/server/AlphaIntegrationTest.java | 19 ++-
.../integration/pack/tests/GreetingController.java | 13 ++
.../saga/integration/pack/tests/PackIT.java | 184 +++++++++++++--------
.../grpc/LoadBalancedClusterMessageSender.java | 1 -
.../grpc/LoadBalancedClusterMessageSenderTest.java | 4 +-
.../saga/omega/context/CompensationContext.java | 61 +++++++
.../saga/omega/context/OmegaContext.java | 51 ------
.../saga/omega/context/annotations/SagaStart.java | 1 +
.../saga/omega/context/OmegaContextTest.java | 18 --
.../saga/omega/spring/OmegaSpringConfig.java | 6 +
.../spring/CompensableAnnotationProcessor.java | 9 +-
.../spring/CompensableMethodCheckingCallback.java | 10 +-
.../transaction/spring/ExecutorFieldCallback.java | 13 +-
.../spring/TransactionAspectConfig.java | 16 +-
.../spring/TransactionInterceptionTest.java | 74 +++++----
omega/omega-transaction/pom.xml | 20 ++-
...nterceptor.java => CompensableInterceptor.java} | 25 ++-
.../transaction/CompensationMessageHandler.java | 10 +-
...Interceptor.java => EventAwareInterceptor.java} | 26 ++-
.../transaction/FailedTransactionInterceptor.java | 30 ----
...erializer.java => OmegaTxTimeoutException.java} | 6 +-
.../transaction/SagaStartAnnotationProcessor.java | 20 ++-
.../saga/omega/transaction/SagaStartAspect.java | 93 +++++++++++
.../omega/transaction/TimeAwareInterceptor.java | 55 ++++++
.../saga/omega/transaction/TransactionAspect.java | 102 ++++--------
.../omega/transaction/annotations/Compensable.java | 2 +
...orTest.java => CompensableInterceptorTest.java} | 53 +++++-
.../CompensationMessageHandlerTest.java | 8 +-
.../PostTransactionInterceptorTest.java | 53 ------
.../SagaStartAnnotationProcessorTest.java | 26 ++-
.../omega/transaction/SagaStartAspectTest.java | 153 +++++++++++++++++
.../transaction/TimeAwareInterceptorTest.java | 135 +++++++++++++++
.../omega/transaction/TransactionAspectTest.java | 158 ++++++++++++++++++
.../src/test/resources/log4j2-test.xml | 0
.../TransactionClientHttpRequestInterceptor.java | 18 +-
.../TransactionHandlerInterceptor.java | 16 +-
.../TransactionHandlerInterceptorTest.java | 8 +-
41 files changed, 1121 insertions(+), 429 deletions(-)
create mode 100644
omega/omega-context/src/main/java/org/apache/servicecomb/saga/omega/context/CompensationContext.java
rename
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/{PostTransactionInterceptor.java
=> CompensableInterceptor.java} (50%)
rename
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/{PreTransactionInterceptor.java
=> EventAwareInterceptor.java} (55%)
delete mode 100644
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/FailedTransactionInterceptor.java
copy
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/{MessageSerializer.java
=> OmegaTxTimeoutException.java} (86%)
create mode 100644
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/SagaStartAspect.java
create mode 100644
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/TimeAwareInterceptor.java
rename
omega/omega-transaction/src/test/java/org/apache/servicecomb/saga/omega/transaction/{PreTransactionInterceptorTest.java
=> CompensableInterceptorTest.java} (50%)
delete mode 100644
omega/omega-transaction/src/test/java/org/apache/servicecomb/saga/omega/transaction/PostTransactionInterceptorTest.java
create mode 100644
omega/omega-transaction/src/test/java/org/apache/servicecomb/saga/omega/transaction/SagaStartAspectTest.java
create mode 100644
omega/omega-transaction/src/test/java/org/apache/servicecomb/saga/omega/transaction/TimeAwareInterceptorTest.java
create mode 100644
omega/omega-transaction/src/test/java/org/apache/servicecomb/saga/omega/transaction/TransactionAspectTest.java
copy {saga-spring =>
omega/omega-transaction}/src/test/resources/log4j2-test.xml (100%)
--
To stop receiving notification emails like this one, please contact
['"commits@servicecomb.apache.org" <commits@servicecomb.apache.org>'].
