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 bfca3a4 Update the mailing list address.
new 67228ec SCB-96 added new module omega
new de1479a SCB-96 sent serialized message pre transactional
new 7fb580f SCB-96 omega context to save tx id
new 9ef3cb2 SCB-96 separated spring related classes to a different module
new 716c434 SCB-96 encapsulated args into event
new 70bafcf SCB-96 added local and parent tx id to keep track of entire
tx graph
new a7b9421 SCB-96 added post transaction interception
new 0eb405e SCB-96 invoked compensation method annotated with Compensable
new fa6030e SCB-96 checked existence of matching compensation method on
startup
new e518e09 added interceptor for rest template
new e8c2ef4 updated package path
new 489e8c0 SCB-96 made sure context is cleaned up on compensation
new 68229f5 SCB-96 linked tx ids with omega context and request headers
new 75b112e SCB-96 for the sake of code coverage
The 14 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:
integration-tests/coverage-aggregate/pom.xml | 16 ++
{saga-discovery => omega/omega-context}/pom.xml | 23 ++-
.../saga/omega/context}/IdGenerator.java | 2 +-
.../saga/omega/context/OmegaContext.java | 120 +++++++++++++++
.../saga/omega/context/OmegaContextTest.java | 101 ++++++++++++
{saga-format => omega/omega-spring-tx}/pom.xml | 51 ++++---
.../spring/CompensableAnnotationProcessor.java | 36 ++---
.../spring/CompensableMethodCheckingCallback.java | 55 +++++++
.../spring/TransactionAspectConfig.java | 26 ++--
.../spring/CompensableAnnotationCheckingTest.java | 37 ++---
.../transaction/spring/MisconfiguredService.java | 24 ++-
.../spring/TransactionInterceptionTest.java | 169 +++++++++++++++++++++
.../transaction/spring/TransactionTestMain.java | 7 +-
.../spring/TransactionalUserService.java | 26 ++--
.../saga/omega/transaction/spring/User.java | 65 ++++----
.../omega/transaction/spring/UserRepository.java | 8 +-
{saga-format => omega/omega-transaction}/pom.xml | 41 ++---
.../omega/transaction/MessageDeserializer.java | 6 +-
.../saga/omega/transaction/MessageHandler.java | 6 +-
.../saga/omega/transaction/MessageSender.java | 6 +-
.../saga/omega/transaction/MessageSerializer.java | 6 +-
.../transaction/PostTransactionInterceptor.java | 25 ++-
.../transaction/PreTransactionInterceptor.java | 25 ++-
.../saga/omega/transaction/TransactionAspect.java | 77 ++++++++++
.../saga/omega/transaction/TxEndedEvent.java | 9 +-
.../saga/omega/transaction/TxEvent.java | 41 +++--
.../saga/omega/transaction/TxStartedEvent.java | 12 +-
.../omega/transaction/annotations/Compensable.java | 22 ++-
.../PostTransactionInterceptorTest.java | 50 ++++++
.../transaction/PreTransactionInterceptorTest.java | 58 +++++++
.../omega-transport-resttemplate}/pom.xml | 42 ++---
.../transport/resttemplate/RestTemplateConfig.java | 30 ++--
.../TransactionClientHttpRequestInterceptor.java | 72 +++++++++
.../transport/resttemplate/UniqueIdGenerator.java | 14 +-
...ransactionClientHttpRequestInterceptorTest.java | 102 +++++++++++++
.../resttemplate/UniqueIdGeneratorTest.java | 60 ++++++++
.../omega-transport}/pom.xml | 39 ++---
{saga-demo => omega}/pom.xml | 37 ++---
pom.xml | 21 +++
39 files changed, 1219 insertions(+), 348 deletions(-)
copy {saga-discovery => omega/omega-context}/pom.xml (64%)
copy {saga-core/src/main/java/io/servicecomb/saga/core =>
omega/omega-context/src/main/java/io/servicecomb/saga/omega/context}/IdGenerator.java
(95%)
create mode 100644
omega/omega-context/src/main/java/io/servicecomb/saga/omega/context/OmegaContext.java
create mode 100644
omega/omega-context/src/test/java/io/servicecomb/saga/omega/context/OmegaContextTest.java
copy {saga-format => omega/omega-spring-tx}/pom.xml (67%)
copy saga-core/src/main/java/io/servicecomb/saga/core/FailedSagaResponse.java
=>
omega/omega-spring-tx/src/main/java/io/servicecomb/saga/omega/transaction/spring/CompensableAnnotationProcessor.java
(53%)
create mode 100644
omega/omega-spring-tx/src/main/java/io/servicecomb/saga/omega/transaction/spring/CompensableMethodCheckingCallback.java
copy
transports/transport-httpclient-spring/src/main/java/io/servicecomb/saga/transports/HttpClientTransportConfig.java
=>
omega/omega-spring-tx/src/main/java/io/servicecomb/saga/omega/transaction/spring/TransactionAspectConfig.java
(58%)
copy
saga-core/src/test/java/io/servicecomb/saga/core/CompositeSagaLogTest.java =>
omega/omega-spring-tx/src/test/java/io/servicecomb/saga/omega/transaction/spring/CompensableAnnotationCheckingTest.java
(51%)
copy
saga-core/src/main/java/io/servicecomb/saga/core/dag/SingleLeafDirectedAcyclicGraph.java
=>
omega/omega-spring-tx/src/test/java/io/servicecomb/saga/omega/transaction/spring/MisconfiguredService.java
(69%)
create mode 100644
omega/omega-spring-tx/src/test/java/io/servicecomb/saga/omega/transaction/spring/TransactionInterceptionTest.java
copy
saga-demo/conditional-transaction-demo/payment/src/main/java/io/servicecomb/saga/demo/conditional/transaction/payment/PaymentApplication.java
=>
omega/omega-spring-tx/src/test/java/io/servicecomb/saga/omega/transaction/spring/TransactionTestMain.java
(86%)
copy
saga-core/src/main/java/io/servicecomb/saga/core/dag/SingleLeafDirectedAcyclicGraph.java
=>
omega/omega-spring-tx/src/test/java/io/servicecomb/saga/omega/transaction/spring/TransactionalUserService.java
(57%)
copy saga-core/src/main/java/io/servicecomb/saga/core/dag/Node.java =>
omega/omega-spring-tx/src/test/java/io/servicecomb/saga/omega/transaction/spring/User.java
(53%)
copy saga-core/src/main/java/io/servicecomb/saga/core/IdGenerator.java =>
omega/omega-spring-tx/src/test/java/io/servicecomb/saga/omega/transaction/spring/UserRepository.java
(82%)
copy {saga-format => omega/omega-transaction}/pom.xml (65%)
copy saga-core/src/main/java/io/servicecomb/saga/core/PersistentLog.java =>
omega/omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction/MessageDeserializer.java
(86%)
copy saga-core/src/main/java/io/servicecomb/saga/core/PersistentLog.java =>
omega/omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction/MessageHandler.java
(87%)
copy saga-core/src/main/java/io/servicecomb/saga/core/PersistentLog.java =>
omega/omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction/MessageSender.java
(88%)
copy saga-core/src/main/java/io/servicecomb/saga/core/PersistentLog.java =>
omega/omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction/MessageSerializer.java
(87%)
copy saga-core/src/main/java/io/servicecomb/saga/core/SagaEvent.java =>
omega/omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction/PostTransactionInterceptor.java
(63%)
copy saga-core/src/main/java/io/servicecomb/saga/core/SagaEvent.java =>
omega/omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction/PreTransactionInterceptor.java
(61%)
create mode 100644
omega/omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction/TransactionAspect.java
copy
saga-core/src/main/java/io/servicecomb/saga/core/SagaStartFailedException.java
=>
omega/omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction/TxEndedEvent.java
(79%)
copy
saga-format/src/main/java/io/servicecomb/saga/format/JacksonRestFallback.java
=>
omega/omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction/TxEvent.java
(54%)
copy saga-core/src/main/java/io/servicecomb/saga/core/SagaException.java =>
omega/omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction/TxStartedEvent.java
(77%)
copy saga-core/src/main/java/io/servicecomb/saga/core/Compensation.java =>
omega/omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction/annotations/Compensable.java
(69%)
create mode 100644
omega/omega-transaction/src/test/java/io/servicecomb/saga/omega/transaction/PostTransactionInterceptorTest.java
create mode 100644
omega/omega-transaction/src/test/java/io/servicecomb/saga/omega/transaction/PreTransactionInterceptorTest.java
copy {integration-tests =>
omega/omega-transport/omega-transport-resttemplate}/pom.xml (57%)
copy
transports/transport-httpclient-spring/src/main/java/io/servicecomb/saga/transports/HttpClientTransportConfig.java
=>
omega/omega-transport/omega-transport-resttemplate/src/main/java/io/servicecomb/saga/omega/transport/resttemplate/RestTemplateConfig.java
(54%)
create mode 100644
omega/omega-transport/omega-transport-resttemplate/src/main/java/io/servicecomb/saga/omega/transport/resttemplate/TransactionClientHttpRequestInterceptor.java
copy saga-core/src/main/java/io/servicecomb/saga/core/LongIdGenerator.java =>
omega/omega-transport/omega-transport-resttemplate/src/main/java/io/servicecomb/saga/omega/transport/resttemplate/UniqueIdGenerator.java
(75%)
create mode 100644
omega/omega-transport/omega-transport-resttemplate/src/test/java/io/servicecomb/saga/omega/transport/resttemplate/TransactionClientHttpRequestInterceptorTest.java
create mode 100644
omega/omega-transport/omega-transport-resttemplate/src/test/java/io/servicecomb/saga/omega/transport/resttemplate/UniqueIdGeneratorTest.java
copy {transports/transport-httpclient => omega/omega-transport}/pom.xml (67%)
copy {saga-demo => omega}/pom.xml (65%)
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
