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 040ae38 SCB-130 Updated the Github PR template
new d58529f SCB-96 added request interceptor
new ed86c2e SCB-96 retrieve ids in header and put it into omega context
new d42a6da SCB-97 alpha is able to persist received events
new 2881abb SCB-97 removed unnecessary dependency on serializer
new 5b2194a SCB-97 made alpha server port configurable with default 8080
new 0395ee4 SCB-97 glued omega & alpha together
new eb79f26 SCB-97 glued request interception with transaction aop
new 20cdc58 SCB-97 ensured events are persisted
new 0b7ee11 SCB-97 moved docker plugin config to profile
new 166b32b SCB-97 closed thrift connections on shutdown
new 43ab34c SCB-97 ensured tx ids are linked between services
The 11 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:
{omega/omega-context => alpha/alpha-core}/pom.xml | 14 +-
.../io/servicecomb/saga/alpha/core}/TxEvent.java | 37 ++-
.../saga/alpha/core/TxEventRepository.java | 6 +-
{saga-web => alpha/alpha-server}/pom.xml | 65 +++---
.../saga/alpha/server/AlphaApplication.java | 6 +-
.../servicecomb/saga/alpha/server/AlphaConfig.java | 23 +-
.../saga/alpha/server/SpringTxEventRepository.java | 17 +-
.../alpha/server/SwiftTxEventEndpointImpl.java | 41 ++--
.../saga/alpha/server/ThriftStartable.java | 26 ++-
.../saga/alpha/server/TxEventEnvelope.java | 57 ++---
.../alpha/server/TxEventEnvelopeRepository.java | 5 +-
.../src/main/resources/application.yaml | 6 -
.../alpha-server}/src/main/resources/log4j2.xml | 0
.../src/main/resources/schema-mysql.sql | 11 +
.../saga/alpha/server/AlphaIntegrationTest.java | 83 +++++++
{omega/omega-context => alpha}/pom.xml | 19 +-
integration-tests/coverage-aggregate/pom.xml | 13 ++
integration-tests/pack-tests/pom.xml | 258 +++++++++++++++++++++
.../pack/tests/GreetingApplication.java | 10 +-
.../integration/pack/tests/GreetingController.java | 53 +++++
.../integration/pack/tests/GreetingService.java | 27 ++-
.../saga/integration/pack/tests/PackIT.java | 86 +++++++
.../integration/pack/tests/TxEventEnvelope.java | 49 ++--
.../pack/tests/TxEventEnvelopeRepository.java | 7 +-
.../src/test}/resources/application.yaml | 10 -
integration-tests/pom.xml | 1 +
.../omega-connector-thrift}/pom.xml | 30 +--
.../connector/thrift/ThriftMessageSender.java} | 42 ++--
.../connector/thrift/ThriftMessageSenderTest.java | 79 +++++++
omega/{omega-context => omega-connector}/pom.xml | 16 +-
.../saga/omega/context/OmegaContext.java | 20 ++
.../saga/omega/context}/UniqueIdGenerator.java | 5 +-
.../saga/omega/context/OmegaContextTest.java | 2 +-
omega/{omega-context => omega-format}/pom.xml | 13 +-
.../saga/omega/format/NativeMessageFormat.java | 53 +++++
.../saga/omega/format/NativeMessageFormatTest.java | 70 ++++++
.../pom.xml | 16 +-
.../saga/omega/spring/EnableOmega.java} | 12 +-
.../saga/omega/spring/OmegaSpringConfig.java | 109 +++++++++
.../spring/CompensableMethodCheckingCallback.java | 3 +-
.../spring/TransactionAspectConfig.java | 11 +-
.../spring/CompensableAnnotationCheckingTest.java | 2 +-
.../spring/TransactionInterceptionTest.java | 35 +--
.../omega/transaction/MessageDeserializer.java | 2 +-
.../saga/omega/transaction/MessageSender.java | 2 +-
.../{MessageHandler.java => OmegaException.java} | 7 +-
.../transaction/PostTransactionInterceptor.java | 6 +-
.../transaction/PreTransactionInterceptor.java | 6 +-
.../saga/omega/transaction/TransactionAspect.java | 6 +-
.../saga/omega/transaction/TxEvent.java | 10 +-
.../PostTransactionInterceptorTest.java | 5 +-
.../transaction/PreTransactionInterceptorTest.java | 15 +-
.../omega-transport-resttemplate/pom.xml | 8 +
.../transport/resttemplate/RestTemplateConfig.java | 10 +-
.../TransactionClientHttpRequestInterceptor.java | 19 +-
.../TransactionHandlerInterceptor.java | 70 ++++++
.../{RestTemplateConfig.java => WebConfig.java} | 33 ++-
.../src/main/resources/META-INF/spring.factories | 4 +-
...ransactionClientHttpRequestInterceptorTest.java | 10 +-
.../TransactionHandlerInterceptorTest.java | 85 +++++++
.../resttemplate/UniqueIdGeneratorTest.java | 2 +
omega/pom.xml | 3 +
.../pack-contract-thrift}/pom.xml | 14 +-
.../saga/pack/contracts/thrift/SwiftTxEvent.java | 38 ++-
.../contracts/thrift/SwiftTxEventEndpoint.java | 11 +-
{omega/omega-context => pack-contracts}/pom.xml | 19 +-
pom.xml | 67 +++++-
.../conditional-transaction-demo-tests/pom.xml | 2 +-
.../demo-tests/pom.xml | 2 +-
69 files changed, 1513 insertions(+), 391 deletions(-)
copy {omega/omega-context => alpha/alpha-core}/pom.xml (78%)
copy
{omega/omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction =>
alpha/alpha-core/src/main/java/io/servicecomb/saga/alpha/core}/TxEvent.java
(67%)
copy saga-core/src/main/java/io/servicecomb/saga/core/PersistentLog.java =>
alpha/alpha-core/src/main/java/io/servicecomb/saga/alpha/core/TxEventRepository.java
(88%)
copy {saga-web => alpha/alpha-server}/pom.xml (69%)
copy
omega/omega-spring-tx/src/test/java/io/servicecomb/saga/omega/transaction/spring/TransactionTestMain.java
=>
alpha/alpha-server/src/main/java/io/servicecomb/saga/alpha/server/AlphaApplication.java
(87%)
copy
transports/transport-httpclient-spring/src/main/java/io/servicecomb/saga/transports/HttpClientTransportConfig.java
=>
alpha/alpha-server/src/main/java/io/servicecomb/saga/alpha/server/AlphaConfig.java
(64%)
copy saga-core/src/test/java/io/servicecomb/saga/core/DummyEvent.java =>
alpha/alpha-server/src/main/java/io/servicecomb/saga/alpha/server/SpringTxEventRepository.java
(65%)
copy saga-core/src/main/java/io/servicecomb/saga/core/FailedSagaResponse.java
=>
alpha/alpha-server/src/main/java/io/servicecomb/saga/alpha/server/SwiftTxEventEndpointImpl.java
(50%)
copy
omega/omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction/TxStartedEvent.java
=>
alpha/alpha-server/src/main/java/io/servicecomb/saga/alpha/server/ThriftStartable.java
(55%)
copy
omega/omega-spring-tx/src/test/java/io/servicecomb/saga/omega/transaction/spring/User.java
=>
alpha/alpha-server/src/main/java/io/servicecomb/saga/alpha/server/TxEventEnvelope.java
(55%)
copy
omega/omega-spring-tx/src/test/java/io/servicecomb/saga/omega/transaction/spring/UserRepository.java
=>
alpha/alpha-server/src/main/java/io/servicecomb/saga/alpha/server/TxEventEnvelopeRepository.java
(82%)
copy {saga-spring => alpha/alpha-server}/src/main/resources/application.yaml
(95%)
copy {saga-spring => alpha/alpha-server}/src/main/resources/log4j2.xml (100%)
create mode 100644 alpha/alpha-server/src/main/resources/schema-mysql.sql
create mode 100644
alpha/alpha-server/src/test/java/io/servicecomb/saga/alpha/server/AlphaIntegrationTest.java
copy {omega/omega-context => alpha}/pom.xml (78%)
create mode 100644 integration-tests/pack-tests/pom.xml
copy
saga-demo/conditional-transaction-demo/inventory/src/main/java/io/servicecomb/saga/demo/conditional/transaction/inventory/InventoryApplication.java
=>
integration-tests/pack-tests/src/test/java/io/servicecomb/saga/integration/pack/tests/GreetingApplication.java
(82%)
create mode 100644
integration-tests/pack-tests/src/test/java/io/servicecomb/saga/integration/pack/tests/GreetingController.java
copy
omega/omega-spring-tx/src/test/java/io/servicecomb/saga/omega/transaction/spring/MisconfiguredService.java
=>
integration-tests/pack-tests/src/test/java/io/servicecomb/saga/integration/pack/tests/GreetingService.java
(63%)
create mode 100644
integration-tests/pack-tests/src/test/java/io/servicecomb/saga/integration/pack/tests/PackIT.java
copy
omega/omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction/TxEvent.java
=>
integration-tests/pack-tests/src/test/java/io/servicecomb/saga/integration/pack/tests/TxEventEnvelope.java
(57%)
copy
omega/omega-spring-tx/src/test/java/io/servicecomb/saga/omega/transaction/spring/UserRepository.java
=>
integration-tests/pack-tests/src/test/java/io/servicecomb/saga/integration/pack/tests/TxEventEnvelopeRepository.java
(78%)
copy {saga-spring/src/main =>
integration-tests/pack-tests/src/test}/resources/application.yaml (86%)
copy omega/{omega-transport => omega-connector/omega-connector-thrift}/pom.xml
(84%)
copy
omega/{omega-spring-tx/src/main/java/io/servicecomb/saga/omega/transaction/spring/TransactionAspectConfig.java
=>
omega-connector/omega-connector-thrift/src/main/java/io/servicecomb/saga/omega/connector/thrift/ThriftMessageSender.java}
(50%)
create mode 100644
omega/omega-connector/omega-connector-thrift/src/test/java/io/servicecomb/saga/omega/connector/thrift/ThriftMessageSenderTest.java
copy omega/{omega-context => omega-connector}/pom.xml (80%)
rename
omega/{omega-transport/omega-transport-resttemplate/src/main/java/io/servicecomb/saga/omega/transport/resttemplate
=>
omega-context/src/main/java/io/servicecomb/saga/omega/context}/UniqueIdGenerator.java
(89%)
copy omega/{omega-context => omega-format}/pom.xml (84%)
create mode 100644
omega/omega-format/src/main/java/io/servicecomb/saga/omega/format/NativeMessageFormat.java
create mode 100644
omega/omega-format/src/test/java/io/servicecomb/saga/omega/format/NativeMessageFormatTest.java
copy omega/{omega-context => omega-spring-starter}/pom.xml (78%)
copy
omega/{omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction/annotations/Compensable.java
=>
omega-spring-starter/src/main/java/io/servicecomb/saga/omega/spring/EnableOmega.java}
(77%)
create mode 100644
omega/omega-spring-starter/src/main/java/io/servicecomb/saga/omega/spring/OmegaSpringConfig.java
copy
omega/omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction/{MessageHandler.java
=> OmegaException.java} (85%)
create mode 100644
omega/omega-transport/omega-transport-resttemplate/src/main/java/io/servicecomb/saga/omega/transport/resttemplate/TransactionHandlerInterceptor.java
copy
omega/omega-transport/omega-transport-resttemplate/src/main/java/io/servicecomb/saga/omega/transport/resttemplate/{RestTemplateConfig.java
=> WebConfig.java} (57%)
copy {transports/transport-httpclient-spring =>
omega/omega-transport/omega-transport-resttemplate}/src/main/resources/META-INF/spring.factories
(88%)
create mode 100644
omega/omega-transport/omega-transport-resttemplate/src/test/java/io/servicecomb/saga/omega/transport/resttemplate/TransactionHandlerInterceptorTest.java
copy {omega/omega-context => pack-contracts/pack-contract-thrift}/pom.xml (83%)
copy
omega/omega-transaction/src/main/java/io/servicecomb/saga/omega/transaction/TxEvent.java
=>
pack-contracts/pack-contract-thrift/src/main/java/io/servicecomb/saga/pack/contracts/thrift/SwiftTxEvent.java
(62%)
copy
omega/omega-context/src/main/java/io/servicecomb/saga/omega/context/IdGenerator.java
=>
pack-contracts/pack-contract-thrift/src/main/java/io/servicecomb/saga/pack/contracts/thrift/SwiftTxEventEndpoint.java
(73%)
copy {omega/omega-context => pack-contracts}/pom.xml (78%)
--
To stop receiving notification emails like this one, please contact
['"commits@servicecomb.apache.org" <commits@servicecomb.apache.org>'].
