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 0f36948 SCB-104 Removed the get method in the RestTemplateTransport
new 5328f26 SCB-149 removed unnecessary endpoint interface
new a682178 SCB-149 added service name and instance id to contract
new 4e8c376 SCB-149 checked matching of compensation method
new d801105 SCB-149 omega callback signature change
new 314a271 SCB-149 distinguished omega callbacks by service name and
instance id
new 49235b5 SCB-149 pushed failed compensations to a scheduled task queue
The 6 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:
alpha/alpha-core/pom.xml | 9 ++
.../{OmegaCallback.java => AlphaException.java} | 6 +-
.../saga/alpha/core/CompositeOmegaCallback.java | 35 +++---
.../servicecomb/saga/alpha/core/OmegaCallback.java | 2 +-
.../saga/alpha/core/PendingTaskRunner.java | 30 +++--
.../saga/alpha/core/PushBackOmegaCallback.java | 44 +++++---
.../saga/alpha/core/TxConsistentService.java | 3 +-
.../io/servicecomb/saga/alpha/core/TxEvent.java | 17 ++-
.../alpha/core/CompositeOmegaCallbackTest.java | 122 +++++++++++++++++++++
.../saga/alpha/core/PendingTaskRunnerTest.java | 60 ++++++++++
.../saga/alpha/core/PushBackOmegaCallbackTest.java | 65 +++++++++++
.../saga/alpha/core/TxConsistentServiceTest.java | 25 +++--
.../servicecomb/saga/alpha/core/TxEventMaker.java | 19 +++-
.../alpha-core}/src/test/resources/log4j2-test.xml | 0
alpha/alpha-server/pom.xml | 4 +
.../servicecomb/saga/alpha/server/AlphaConfig.java | 30 ++++-
.../saga/alpha/server/GrpcTxEventEndpointImpl.java | 3 +
.../saga/alpha/server/TxEventEnvelope.java | 15 ++-
.../alpha/server/TxEventEnvelopeRepository.java | 2 +-
.../src/main/resources/schema-mysql.sql | 2 +
.../saga/alpha/server/AlphaIntegrationTest.java | 36 +++---
integration-tests/coverage-aggregate/pom.xml | 4 +
.../saga/integration/pack/tests/PackIT.java | 15 ++-
.../integration/pack/tests/TxEventEnvelope.java | 10 ++
.../connector/grpc/GrpcClientMessageSender.java | 17 ++-
.../connector/grpc/GrpcTxEventEndpointImpl.java | 39 -------
.../grpc/GrpcClientMessageSenderTest.java | 90 ---------------
.../{UniqueIdGenerator.java => ServiceConfig.java} | 26 ++++-
.../saga/omega/spring/OmegaSpringConfig.java | 35 +++---
.../pack/contract/grpc/GrpcTxEventEndpoint.java | 25 -----
.../src/main/proto/GrpcTxEvent.proto | 2 +
31 files changed, 529 insertions(+), 263 deletions(-)
copy
alpha/alpha-core/src/main/java/io/servicecomb/saga/alpha/core/{OmegaCallback.java
=> AlphaException.java} (86%)
copy
saga-format/src/main/java/io/servicecomb/saga/format/JacksonRestFallback.java
=>
alpha/alpha-core/src/main/java/io/servicecomb/saga/alpha/core/CompositeOmegaCallback.java
(51%)
copy
saga-core/src/test/java/io/servicecomb/saga/core/dag/GraphBasedSagaExecutionComponentTest.java
=>
alpha/alpha-core/src/main/java/io/servicecomb/saga/alpha/core/PendingTaskRunner.java
(53%)
copy saga-core/src/main/java/io/servicecomb/saga/core/BackwardRecovery.java =>
alpha/alpha-core/src/main/java/io/servicecomb/saga/alpha/core/PushBackOmegaCallback.java
(52%)
create mode 100644
alpha/alpha-core/src/test/java/io/servicecomb/saga/alpha/core/CompositeOmegaCallbackTest.java
create mode 100644
alpha/alpha-core/src/test/java/io/servicecomb/saga/alpha/core/PendingTaskRunnerTest.java
create mode 100644
alpha/alpha-core/src/test/java/io/servicecomb/saga/alpha/core/PushBackOmegaCallbackTest.java
copy
omega/omega-context/src/main/java/io/servicecomb/saga/omega/context/UniqueIdGenerator.java
=>
alpha/alpha-core/src/test/java/io/servicecomb/saga/alpha/core/TxEventMaker.java
(61%)
copy {saga-spring => alpha/alpha-core}/src/test/resources/log4j2-test.xml
(100%)
delete mode 100644
omega/omega-connector/omega-connector-grpc/src/main/java/io/servicecomb/saga/omega/connector/grpc/GrpcTxEventEndpointImpl.java
delete mode 100644
omega/omega-connector/omega-connector-grpc/src/test/java/io/servicecomb/saga/omega/connector/grpc/GrpcClientMessageSenderTest.java
copy
omega/omega-context/src/main/java/io/servicecomb/saga/omega/context/{UniqueIdGenerator.java
=> ServiceConfig.java} (60%)
delete mode 100644
pack-contracts/pack-contract-grpc/src/main/java/io/servicecomb/saga/pack/contract/grpc/GrpcTxEventEndpoint.java
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
