[GitHub] Gannalyo commented on issue #222: Problem for Saga Load Balance Strategy
Gannalyo commented on issue #222: Problem for Saga Load Balance Strategy URL: https://github.com/apache/incubator-servicecomb-saga/issues/222#issuecomment-414203525 Hi Jiang! I upgraded the Saga program(even though an informality version) and I read the source of 'LoadBalancedClusterMessageSender.java'. And I thought it was almost same between the last source and the former in terms of function. How do you think? Or I probably located a wrong position?   By the way, why did you downgrade the JDK version for latest Saga? issue url: https://github.com/apache/incubator-servicecomb-saga/issues/222 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] coveralls edited a comment on issue #256: SCB-853 Rewrite the lamda function in saga-core to support JDK 7
coveralls edited a comment on issue #256: SCB-853 Rewrite the lamda function in saga-core to support JDK 7 URL: https://github.com/apache/incubator-servicecomb-saga/pull/256#issuecomment-414180455 [](https://coveralls.io/builds/18563247) Coverage decreased (-1.9%) to 93.586% when pulling **c89350f33493b9c648985bce7b9fb0c45630579e on SCB-853** into **089ffd7de55cb840540465bf53171d71254d1b89 on master**. This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] WillemJiang commented on a change in pull request #37: update question-and-answer translation
WillemJiang commented on a change in pull request #37: update question-and-answer translation URL: https://github.com/apache/incubator-servicecomb-docs/pull/37#discussion_r211139241 ## File path: java-chassis-reference/en_US/question-and-answer/question_answer.md ## @@ -144,47 +143,47 @@ Caused by: java.lang.ClassFormatError: Method "testInherate" in class ? has ille $ref: "#/definitions/ReponseImpl" ``` -# 问题描述：微服务框架服务调用是否使用长连接 +# Problem: Does the microservices framework service call use long connections? -** 解决方法：** +** Solution:** -http使用的是长连接（有超时时间），highway方式使用的是长连接（一直保持）。 +Http uses a long connection (with a timeout), and the highway mode uses a long connection (always on). -# 问题描述：服务断连服务中心注册信息是否自动删除 +# Problem: Whether the service disconnection service's center registration information is automatically deleted -** 解决方法：** +** Solution:** -服务中心心跳检测到服务实例不可用，只会移除服务实例信息，服务的静态数据不会移除。 +The service center heartbeat detects that the service instance is unavailable, only the service instance information is removed, and the static data of the service is not removed. -# 问题描述：微服务框架如何实现数据多个微服务间透传 +# Problem: How does the microservices framework achieve transparent transmission of data between multiple microservices? -** 解决方法：** +** Solution:** -透传数据塞入： +Transmitting data into: ```java CseHttpEntity httpEntity = new CseHttpEntity<>(xxx); -//透传内容 +//Transparent content Review comment: 透传是传送的意思，不是透明的意思。 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] WillemJiang commented on a change in pull request #36: update .travis.yml for saga and sc
WillemJiang commented on a change in pull request #36: update .travis.yml for saga and sc URL: https://github.com/apache/incubator-servicecomb-docs/pull/36#discussion_r211139070 ## File path: .travis.yml ## @@ -1,6 +1,8 @@ script: - npm install gitbook-cli -g - gitbook build java-chassis-reference docs Review comment: it could be better if the java-chassis has separated directory. This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[incubator-servicecomb-saga] branch master updated: SCB-853 Saga-core supports JDK7 now
This is an automated email from the ASF dual-hosted git repository.
ningjiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git
The following commit(s) were added to refs/heads/master by this push:
new 7e586b5 SCB-853 Saga-core supports JDK7 now
7e586b5 is described below
commit 7e586b569c61b6faafe1d376922a49522fcba848
Author: Willem Jiang
AuthorDate: Mon Aug 20 09:30:14 2018 +0800
SCB-853 Saga-core supports JDK7 now
---
saga-core/pom.xml | 10
.../servicecomb/saga/core/BackwardRecovery.java| 5 ++
.../apache/servicecomb/saga/core/Compensation.java | 32 +--
.../saga/core/CompositeSagaResponse.java | 31 ---
.../apache/servicecomb/saga/core/Descriptive.java | 4 +-
.../org/apache/servicecomb/saga/core/Fallback.java | 17 +-
.../servicecomb/saga/core/ForwardRecovery.java | 5 ++
.../servicecomb/saga/core/GraphBasedSaga.java | 15 +++---
.../saga/core/LoggingRecoveryPolicy.java | 5 ++
.../servicecomb/saga/core/NoOpSagaRequest.java | 6 +++
.../apache/servicecomb/saga/core/Operation.java| 8 +--
.../servicecomb/saga/core/RestOperation.java | 14 +++--
.../apache/servicecomb/saga/core/SagaContext.java | 4 +-
.../servicecomb/saga/core/SagaContextImpl.java | 35 +++-
.../apache/servicecomb/saga/core/SagaEvent.java| 5 ++
.../apache/servicecomb/saga/core/SagaRequest.java | 6 +--
.../servicecomb/saga/core/SagaTaskFactory.java | 10 ++--
.../apache/servicecomb/saga/core/Transaction.java | 18 +++
.../servicecomb/saga/core/TransactionConsumer.java | 5 ++
.../saga/core/dag/ByLevelTraveller.java| 5 +-
.../saga/core/dag/GraphBasedSagaFactory.java | 3 +-
.../servicecomb/saga/core/dag/GraphBuilder.java| 9 ++--
.../saga/core/dag/GraphCycleDetectorImpl.java | 26 +
.../org/apache/servicecomb/saga/core/dag/Node.java | 4 +-
.../servicecomb/saga/core/CompensationImpl.java| 5 ++
.../saga/core/CompositeSagaResponseTest.java | 8 +++
.../servicecomb/saga/core/ForwardRecoveryTest.java | 7 ++-
.../servicecomb/saga/core/RestOperationTest.java | 18 ---
.../servicecomb/saga/core/RetrySagaLogTest.java| 19 +--
.../saga/core/SagaExecutionComponentTestBase.java | 44 +++
.../servicecomb/saga/core/SagaIntegrationTest.java | 63 ++
.../dag/DirectedAcyclicGraphTraversalTest.java | 4 +-
.../saga/core/dag/GraphBuilderTest.java| 40 --
.../saga/core/dag/GraphCycleDetectorTest.java | 3 +-
.../servicecomb/saga/format/JacksonFallback.java | 11
35 files changed, 366 insertions(+), 138 deletions(-)
diff --git a/saga-core/pom.xml b/saga-core/pom.xml
index fd1b47c..e460b1a 100644
--- a/saga-core/pom.xml
+++ b/saga-core/pom.xml
@@ -95,6 +95,16 @@
+
+org.apache.maven.plugins
+maven-compiler-plugin
+3.1
+
+ UTF-8
+ 1.7
+ 1.7
+
+
diff --git
a/saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java
b/saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java
index e46de2f..799dbbf 100644
---
a/saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java
+++
b/saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java
@@ -46,4 +46,9 @@ public class BackwardRecovery implements RecoveryPolicy {
throw e;
}
}
+
+ @Override
+ public String description() {
+return getClass().getSimpleName();
+ }
}
diff --git
a/saga-core/src/main/java/org/apache/servicecomb/saga/core/Compensation.java
b/saga-core/src/main/java/org/apache/servicecomb/saga/core/Compensation.java
index f642011..a6a352b 100644
--- a/saga-core/src/main/java/org/apache/servicecomb/saga/core/Compensation.java
+++ b/saga-core/src/main/java/org/apache/servicecomb/saga/core/Compensation.java
@@ -20,14 +20,40 @@ package org.apache.servicecomb.saga.core;
public interface Compensation extends Operation {
Compensation SAGA_START_COMPENSATION = new Compensation() {
+@Override
+public SagaResponse send(String address) {
+ return SUCCESSFUL_SAGA_RESPONSE;
+}
+
+@Override
+public SagaResponse send(String address, SagaResponse response) {
+ return send(address);
+}
+
+@Override
+public int retries() {
+ return DEFAULT_RETRIES;
+}
};
Compensation SAGA_END_COMPENSATION = new Compensation() {
+@Override
+public SagaResponse send(String address) {
+ return SUCCESSFUL_SAGA_RESPONSE;
+}
+
+@Override
+public SagaResponse send(String address, SagaResponse response) {
+ return send(address);
+}
+
+@Override
+public int retries() {
+ return DEFAULT_RETRIES;
+}
};
int DEFAULT_RETRIES = 3;
- default
[GitHub] WillemJiang closed pull request #256: SCB-853 Rewrite the lamda function in saga-core to support JDK 7
WillemJiang closed pull request #256: SCB-853 Rewrite the lamda function in saga-core to support JDK 7 URL: https://github.com/apache/incubator-servicecomb-saga/pull/256 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[incubator-servicecomb-saga] branch SCB-853 updated (664591e -> c89350f)
This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a change to branch SCB-853 in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git. from 664591e SCB-853 Saga-core supports JDK7 now add 8a2bcbe SCB-852 Split akka related code to saga-core-akka add c1f0a10 SCB-852 Fixed the build error by adding saga-core-akka module add 089ffd7 SCB-852 Added the uncommitted pom of saga-core-akka new c89350f Merge branch 'master' into SCB-853 The 1 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:
[incubator-servicecomb-saga] 01/01: Merge branch 'master' into SCB-853
This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch SCB-853 in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git commit c89350f33493b9c648985bce7b9fb0c45630579e Merge: 664591e 089ffd7 Author: Willem Jiang AuthorDate: Mon Aug 20 12:30:09 2018 +0800 Merge branch 'master' into SCB-853
[incubator-servicecomb-saga] 01/01: SCB-853 Saga-core supports JDK7 now
This is an automated email from the ASF dual-hosted git repository.
ningjiang pushed a commit to branch SCB-853
in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git
commit 664591e7baf47c765355c23e6a34fac061fbb270
Author: Willem Jiang
AuthorDate: Mon Aug 20 09:30:14 2018 +0800
SCB-853 Saga-core supports JDK7 now
---
saga-core/pom.xml | 10
.../servicecomb/saga/core/BackwardRecovery.java| 5 ++
.../apache/servicecomb/saga/core/Compensation.java | 32 +--
.../saga/core/CompositeSagaResponse.java | 31 ---
.../apache/servicecomb/saga/core/Descriptive.java | 4 +-
.../org/apache/servicecomb/saga/core/Fallback.java | 17 +-
.../servicecomb/saga/core/ForwardRecovery.java | 5 ++
.../servicecomb/saga/core/GraphBasedSaga.java | 15 +++---
.../saga/core/LoggingRecoveryPolicy.java | 5 ++
.../servicecomb/saga/core/NoOpSagaRequest.java | 6 +++
.../apache/servicecomb/saga/core/Operation.java| 8 +--
.../servicecomb/saga/core/RestOperation.java | 14 +++--
.../apache/servicecomb/saga/core/SagaContext.java | 4 +-
.../servicecomb/saga/core/SagaContextImpl.java | 35 +++-
.../apache/servicecomb/saga/core/SagaEvent.java| 5 ++
.../apache/servicecomb/saga/core/SagaRequest.java | 6 +--
.../servicecomb/saga/core/SagaTaskFactory.java | 10 ++--
.../apache/servicecomb/saga/core/Transaction.java | 18 +++
.../servicecomb/saga/core/TransactionConsumer.java | 5 ++
.../saga/core/dag/ByLevelTraveller.java| 5 +-
.../saga/core/dag/GraphBasedSagaFactory.java | 3 +-
.../servicecomb/saga/core/dag/GraphBuilder.java| 9 ++--
.../saga/core/dag/GraphCycleDetectorImpl.java | 26 +
.../org/apache/servicecomb/saga/core/dag/Node.java | 4 +-
.../servicecomb/saga/core/CompensationImpl.java| 5 ++
.../saga/core/CompositeSagaResponseTest.java | 8 +++
.../servicecomb/saga/core/ForwardRecoveryTest.java | 7 ++-
.../servicecomb/saga/core/RestOperationTest.java | 18 ---
.../servicecomb/saga/core/RetrySagaLogTest.java| 19 +--
.../saga/core/SagaExecutionComponentTestBase.java | 44 +++
.../servicecomb/saga/core/SagaIntegrationTest.java | 63 ++
.../dag/DirectedAcyclicGraphTraversalTest.java | 4 +-
.../saga/core/dag/GraphBuilderTest.java| 40 --
.../saga/core/dag/GraphCycleDetectorTest.java | 3 +-
.../servicecomb/saga/format/JacksonFallback.java | 11
35 files changed, 366 insertions(+), 138 deletions(-)
diff --git a/saga-core/pom.xml b/saga-core/pom.xml
index fd1b47c..e460b1a 100644
--- a/saga-core/pom.xml
+++ b/saga-core/pom.xml
@@ -95,6 +95,16 @@
+
+org.apache.maven.plugins
+maven-compiler-plugin
+3.1
+
+ UTF-8
+ 1.7
+ 1.7
+
+
diff --git
a/saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java
b/saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java
index e46de2f..799dbbf 100644
---
a/saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java
+++
b/saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java
@@ -46,4 +46,9 @@ public class BackwardRecovery implements RecoveryPolicy {
throw e;
}
}
+
+ @Override
+ public String description() {
+return getClass().getSimpleName();
+ }
}
diff --git
a/saga-core/src/main/java/org/apache/servicecomb/saga/core/Compensation.java
b/saga-core/src/main/java/org/apache/servicecomb/saga/core/Compensation.java
index f642011..a6a352b 100644
--- a/saga-core/src/main/java/org/apache/servicecomb/saga/core/Compensation.java
+++ b/saga-core/src/main/java/org/apache/servicecomb/saga/core/Compensation.java
@@ -20,14 +20,40 @@ package org.apache.servicecomb.saga.core;
public interface Compensation extends Operation {
Compensation SAGA_START_COMPENSATION = new Compensation() {
+@Override
+public SagaResponse send(String address) {
+ return SUCCESSFUL_SAGA_RESPONSE;
+}
+
+@Override
+public SagaResponse send(String address, SagaResponse response) {
+ return send(address);
+}
+
+@Override
+public int retries() {
+ return DEFAULT_RETRIES;
+}
};
Compensation SAGA_END_COMPENSATION = new Compensation() {
+@Override
+public SagaResponse send(String address) {
+ return SUCCESSFUL_SAGA_RESPONSE;
+}
+
+@Override
+public SagaResponse send(String address, SagaResponse response) {
+ return send(address);
+}
+
+@Override
+public int retries() {
+ return DEFAULT_RETRIES;
+}
};
int DEFAULT_RETRIES = 3;
- default int retries() {
-return DEFAULT_RETRIES;
- }
+ int retries();
}
diff --git
[incubator-servicecomb-saga] branch SCB-853 updated (bd60f3f -> 664591e)
This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a change to branch SCB-853 in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git. omit bd60f3f Merge branch 'master' into SCB-853 omit 089ffd7 SCB-852 Added the uncommitted pom of saga-core-akka omit c1f0a10 SCB-852 Fixed the build error by adding saga-core-akka module omit 8a2bcbe SCB-852 Split akka related code to saga-core-akka omit ce83f17 SCB-853 Saga-core noew supports JDK7 new 664591e SCB-853 Saga-core supports JDK7 now This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (bd60f3f) \ N -- N -- N refs/heads/SCB-853 (664591e) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. The 1 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:
[incubator-servicecomb-saga] 01/01: Merge branch 'master' into SCB-853
This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch SCB-853 in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git commit bd60f3fa9ce209df7306d06b8e6bc8d029ce8a0d Merge: ce83f17 089ffd7 Author: Willem Jiang AuthorDate: Mon Aug 20 12:26:45 2018 +0800 Merge branch 'master' into SCB-853
[incubator-servicecomb-saga] branch SCB-852 deleted (was d847a1a)
This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a change to branch SCB-852 in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git. was d847a1a SCB-852 Added the uncommitted pom of saga-core-akka The revisions that were on this branch are still contained in other references; therefore, this change does not discard any commits from the repository.
[GitHub] WillemJiang commented on issue #255: SCB-852 Create saga-core-akka module
WillemJiang commented on issue #255: SCB-852 Create saga-core-akka module URL: https://github.com/apache/incubator-servicecomb-saga/pull/255#issuecomment-414193865 After Running the build on my Mac, all test passed. This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[incubator-servicecomb-saga] 01/03: SCB-852 Split akka related code to saga-core-akka
This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git commit 8a2bcbec1f9f58a2ec2f43498bff506effcce93b Author: Willem Jiang AuthorDate: Sun Aug 19 20:39:26 2018 +0800 SCB-852 Split akka related code to saga-core-akka --- pom.xml| 11 +++ .../saga/core/actors/ActorBasedSaga.java | 2 +- .../saga/core/actors/ActorBasedSagaFactory.java| 0 .../saga/core/actors/CompletionCallbackActor.java | 0 .../saga/core/actors/EventContextImpl.java | 0 .../servicecomb/saga/core/actors/RequestActor.java | 0 .../saga/core/actors/RequestActorBuilder.java | 0 .../saga/core/actors/RequestActorContext.java | 0 .../saga/core/actors/messages/AbortMessage.java| 0 .../core/actors/messages/AbortRecoveryMessage.java | 0 .../core/actors/messages/CompensateMessage.java| 0 .../messages/CompensationRecoveryMessage.java | 0 .../saga/core/actors/messages/FailMessage.java | 0 .../saga/core/actors/messages/Message.java | 0 .../saga/core/actors/messages/TransactMessage.java | 1 + .../messages/TransactionRecoveryMessage.java | 0 .../ActorBasedSagaExecutionComponentTest.java | 2 +- .../core/actors/ActorBasedSagaIntegrationTest.java | 16 +- .../core/actors/CompletionCallbackActorTest.java | 4 +-- .../saga/core/actors/EventContextImplTest.java | 0 .../saga/core/actors/RequestActorBuilderTest.java | 2 +- .../saga/core/actors/RequestActorTest.java | 0 saga-core-akka/src/test/resources/application.conf | 21 + saga-core-akka/src/test/resources/log4j2.xml | 30 ++ saga-core/pom.xml | 36 ++ saga-spring/pom.xml| 4 +++ 26 files changed, 96 insertions(+), 33 deletions(-) diff --git a/pom.xml b/pom.xml index e8cfe75..542fb1c 100644 --- a/pom.xml +++ b/pom.xml @@ -252,6 +252,17 @@ org.apache.servicecomb.saga +saga-core-akka +0.3.0-SNAPSHOT + + +org.apache.servicecomb.saga +saga-core +test-jar +0.3.0-SNAPSHOT + + +org.apache.servicecomb.saga saga-format 0.3.0-SNAPSHOT diff --git a/saga-core/src/main/java/org/apache/servicecomb/saga/core/actors/ActorBasedSaga.java b/saga-core-akka/src/main/java/org/apache/servicecomb/saga/core/actors/ActorBasedSaga.java similarity index 100% rename from saga-core/src/main/java/org/apache/servicecomb/saga/core/actors/ActorBasedSaga.java rename to saga-core-akka/src/main/java/org/apache/servicecomb/saga/core/actors/ActorBasedSaga.java index bf60f98..36fae1f 100644 --- a/saga-core/src/main/java/org/apache/servicecomb/saga/core/actors/ActorBasedSaga.java +++ b/saga-core-akka/src/main/java/org/apache/servicecomb/saga/core/actors/ActorBasedSaga.java @@ -23,9 +23,9 @@ import org.apache.servicecomb.saga.core.EventContext; import org.apache.servicecomb.saga.core.EventStore; import org.apache.servicecomb.saga.core.NoOpSagaRequest; import org.apache.servicecomb.saga.core.Saga; +import org.apache.servicecomb.saga.core.SagaEvent; import org.apache.servicecomb.saga.core.SagaResponse; import org.apache.servicecomb.saga.core.actors.messages.TransactMessage; -import org.apache.servicecomb.saga.core.SagaEvent; import akka.actor.ActorRef; diff --git a/saga-core/src/main/java/org/apache/servicecomb/saga/core/actors/ActorBasedSagaFactory.java b/saga-core-akka/src/main/java/org/apache/servicecomb/saga/core/actors/ActorBasedSagaFactory.java similarity index 100% rename from saga-core/src/main/java/org/apache/servicecomb/saga/core/actors/ActorBasedSagaFactory.java rename to saga-core-akka/src/main/java/org/apache/servicecomb/saga/core/actors/ActorBasedSagaFactory.java diff --git a/saga-core/src/main/java/org/apache/servicecomb/saga/core/actors/CompletionCallbackActor.java b/saga-core-akka/src/main/java/org/apache/servicecomb/saga/core/actors/CompletionCallbackActor.java similarity index 100% rename from saga-core/src/main/java/org/apache/servicecomb/saga/core/actors/CompletionCallbackActor.java rename to saga-core-akka/src/main/java/org/apache/servicecomb/saga/core/actors/CompletionCallbackActor.java diff --git a/saga-core/src/main/java/org/apache/servicecomb/saga/core/actors/EventContextImpl.java b/saga-core-akka/src/main/java/org/apache/servicecomb/saga/core/actors/EventContextImpl.java similarity index 100% rename from saga-core/src/main/java/org/apache/servicecomb/saga/core/actors/EventContextImpl.java rename to saga-core-akka/src/main/java/org/apache/servicecomb/saga/core/actors/EventContextImpl.java diff --git a/saga-core/src/main/java/org/apache/servicecomb/saga/core/actors/RequestActor.java
[incubator-servicecomb-saga] 02/03: SCB-852 Fixed the build error by adding saga-core-akka module
This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git commit c1f0a10d326e0c0aabc5a5591f5b519ee8c758c3 Author: Willem Jiang AuthorDate: Mon Aug 20 08:40:02 2018 +0800 SCB-852 Fixed the build error by adding saga-core-akka module --- pom.xml | 1 + 1 file changed, 1 insertion(+) diff --git a/pom.xml b/pom.xml index 542fb1c..83e5366 100644 --- a/pom.xml +++ b/pom.xml @@ -32,6 +32,7 @@ saga-core +saga-core-akka transports saga-spring docker-build-config
[GitHub] WillemJiang closed pull request #255: SCB-852 Create saga-core-akka module
WillemJiang closed pull request #255: SCB-852 Create saga-core-akka module URL: https://github.com/apache/incubator-servicecomb-saga/pull/255 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[incubator-servicecomb-saga] 03/03: SCB-852 Added the uncommitted pom of saga-core-akka
This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git commit 089ffd7de55cb840540465bf53171d71254d1b89 Author: Willem Jiang AuthorDate: Mon Aug 20 09:53:39 2018 +0800 SCB-852 Added the uncommitted pom of saga-core-akka --- saga-core-akka/pom.xml | 120 + 1 file changed, 120 insertions(+) diff --git a/saga-core-akka/pom.xml b/saga-core-akka/pom.xml new file mode 100644 index 000..a019a25 --- /dev/null +++ b/saga-core-akka/pom.xml @@ -0,0 +1,120 @@ + + + +http://maven.apache.org/POM/4.0.0; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd;> + +saga +org.apache.servicecomb.saga +0.3.0-SNAPSHOT + + 4.0.0 + + saga-core-akka + Saga::Core::Akka + + + + com.lmax + disruptor + + + org.slf4j + slf4j-api + + + org.apache.logging.log4j + log4j-slf4j-impl + + + org.apache.logging.log4j + log4j-api + + + org.apache.logging.log4j + log4j-core + + + org.apache.servicecomb.saga + saga-core + + + com.typesafe.akka + akka-actor_2.12 + + + com.typesafe.akka + akka-slf4j_2.12 + + + io.kamon + kamon-core_2.12 + + + io.kamon + kamon-annotation_2.12 + + + + + com.typesafe.akka + akka-testkit_2.12 + + + org.scalatest + scalatest_2.12 + + + junit + junit + + + org.hamcrest + hamcrest-all + + + org.mockito + mockito-core + + 1.10.19 + + + org.apache.commons + commons-lang3 + + + org.awaitility + awaitility + + + com.github.seanyinx + unit-scaffolding + + + org.apache.servicecomb.saga + saga-core + test-jar + 0.3.0-SNAPSHOT + test + + + org.apache.servicecomb.saga + saga-core + + + +
[incubator-servicecomb-saga] branch master updated (66344e7 -> 089ffd7)
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 66344e7 Fixed the deprecated warning issues of saga-core
new 8a2bcbe SCB-852 Split akka related code to saga-core-akka
new c1f0a10 SCB-852 Fixed the build error by adding saga-core-akka module
new 089ffd7 SCB-852 Added the uncommitted pom of saga-core-akka
The 3 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:
pom.xml| 12
{saga-core => saga-core-akka}/pom.xml | 19 ++--
.../saga/core/actors/ActorBasedSaga.java | 2 +-
.../saga/core/actors/ActorBasedSagaFactory.java| 0
.../saga/core/actors/CompletionCallbackActor.java | 0
.../saga/core/actors/EventContextImpl.java | 0
.../servicecomb/saga/core/actors/RequestActor.java | 0
.../saga/core/actors/RequestActorBuilder.java | 0
.../saga/core/actors/RequestActorContext.java | 0
.../saga/core/actors/messages/AbortMessage.java| 0
.../core/actors/messages/AbortRecoveryMessage.java | 0
.../core/actors/messages/CompensateMessage.java| 0
.../messages/CompensationRecoveryMessage.java | 0
.../saga/core/actors/messages/FailMessage.java | 0
.../saga/core/actors/messages/Message.java | 0
.../saga/core/actors/messages/TransactMessage.java | 1 +
.../messages/TransactionRecoveryMessage.java | 0
.../ActorBasedSagaExecutionComponentTest.java | 2 +-
.../core/actors/ActorBasedSagaIntegrationTest.java | 16 +-
.../core/actors/CompletionCallbackActorTest.java | 4 +--
.../saga/core/actors/EventContextImplTest.java | 0
.../saga/core/actors/RequestActorBuilderTest.java | 2 +-
.../saga/core/actors/RequestActorTest.java | 0
.../src/test/resources/application.conf| 0
.../src/test}/resources/log4j2.xml | 0
saga-core/pom.xml | 36 ++
saga-spring/pom.xml| 4 +++
27 files changed, 63 insertions(+), 35 deletions(-)
copy {saga-core => saga-core-akka}/pom.xml (86%)
rename {saga-core =>
saga-core-akka}/src/main/java/org/apache/servicecomb/saga/core/actors/ActorBasedSaga.java
(100%)
rename {saga-core =>
saga-core-akka}/src/main/java/org/apache/servicecomb/saga/core/actors/ActorBasedSagaFactory.java
(100%)
rename {saga-core =>
saga-core-akka}/src/main/java/org/apache/servicecomb/saga/core/actors/CompletionCallbackActor.java
(100%)
rename {saga-core =>
saga-core-akka}/src/main/java/org/apache/servicecomb/saga/core/actors/EventContextImpl.java
(100%)
rename {saga-core =>
saga-core-akka}/src/main/java/org/apache/servicecomb/saga/core/actors/RequestActor.java
(100%)
rename {saga-core =>
saga-core-akka}/src/main/java/org/apache/servicecomb/saga/core/actors/RequestActorBuilder.java
(100%)
rename {saga-core =>
saga-core-akka}/src/main/java/org/apache/servicecomb/saga/core/actors/RequestActorContext.java
(100%)
rename {saga-core =>
saga-core-akka}/src/main/java/org/apache/servicecomb/saga/core/actors/messages/AbortMessage.java
(100%)
rename {saga-core =>
saga-core-akka}/src/main/java/org/apache/servicecomb/saga/core/actors/messages/AbortRecoveryMessage.java
(100%)
rename {saga-core =>
saga-core-akka}/src/main/java/org/apache/servicecomb/saga/core/actors/messages/CompensateMessage.java
(100%)
rename {saga-core =>
saga-core-akka}/src/main/java/org/apache/servicecomb/saga/core/actors/messages/CompensationRecoveryMessage.java
(100%)
rename {saga-core =>
saga-core-akka}/src/main/java/org/apache/servicecomb/saga/core/actors/messages/FailMessage.java
(100%)
rename {saga-core =>
saga-core-akka}/src/main/java/org/apache/servicecomb/saga/core/actors/messages/Message.java
(100%)
rename {saga-core =>
saga-core-akka}/src/main/java/org/apache/servicecomb/saga/core/actors/messages/TransactMessage.java
(99%)
rename {saga-core =>
saga-core-akka}/src/main/java/org/apache/servicecomb/saga/core/actors/messages/TransactionRecoveryMessage.java
(100%)
rename {saga-core =>
saga-core-akka}/src/test/java/org/apache/servicecomb/saga/core/actors/ActorBasedSagaExecutionComponentTest.java
(100%)
rename {saga-core =>
saga-core-akka}/src/test/java/org/apache/servicecomb/saga/core/actors/ActorBasedSagaIntegrationTest.java
(100%)
rename {saga-core =>
saga-core-akka}/src/test/java/org/apache/servicecomb/saga/core/actors/CompletionCallbackActorTest.java
(100%)
rename {saga-core =>
saga-core-akka}/src/test/java/org/apache/servicecomb/saga/core/actors/EventContextImplTest.java
(100%)
rename {saga-core =>
[GitHub] imlidian opened a new pull request #37: update question-and-answer translation
imlidian opened a new pull request #37: update question-and-answer translation URL: https://github.com/apache/incubator-servicecomb-docs/pull/37 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] imlidian opened a new pull request #36: update .travis.yml for saga and sc
imlidian opened a new pull request #36: update .travis.yml for saga and sc URL: https://github.com/apache/incubator-servicecomb-docs/pull/36 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] weichao666 commented on a change in pull request #35: modify table Regular expression
weichao666 commented on a change in pull request #35: modify table Regular expression URL: https://github.com/apache/incubator-servicecomb-docs/pull/35#discussion_r211135311 ## File path: java-chassis-reference/zh_CN/build-provider/definition/service-definition.md ## @@ -15,7 +15,7 @@ | 配置项 | 默认值 | 取值范围 | 是否必选 | 含义 | 注意 | | :--- | :--- | :--- | :--- | :--- | :--- | | APPLICATION\_ID | - | - | 是 | 应用名 | - | -| service\_description.name | - | - | 是 | 微服务名 | 应确保app内部唯一。微服务名支持数字、大小写字母和"-"、"\_"、"."三个特殊字符，但是不能以特殊字符作为首尾字符，命名规范为：^\[a-zA-Z0-9\]+$\|^\[a-zA-Z0-9\]\[a-zA-Z0-9\_-.\]\*\[a-zA-Z0-9\]$。 | +| service\_description.name | - | - | 是 | 微服务名 | 应确保app内部唯一。微服务名支持数字、大小写字母和"-"、"\_"、"."三个特殊字符，但是不能以特殊字符作为首尾字符，命名规范为：^\[a-zA-Z0-9\]+$^\[a-zA-Z0-9\]\[a-zA-Z0-9\_-.\]\*\[a-zA-Z0-9\]$。 | Review comment: done This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] liubao68 commented on a change in pull request #35: modify table Regular expression
liubao68 commented on a change in pull request #35: modify table Regular expression URL: https://github.com/apache/incubator-servicecomb-docs/pull/35#discussion_r211134768 ## File path: java-chassis-reference/zh_CN/build-provider/definition/service-definition.md ## @@ -15,7 +15,7 @@ | 配置项 | 默认值 | 取值范围 | 是否必选 | 含义 | 注意 | | :--- | :--- | :--- | :--- | :--- | :--- | | APPLICATION\_ID | - | - | 是 | 应用名 | - | -| service\_description.name | - | - | 是 | 微服务名 | 应确保app内部唯一。微服务名支持数字、大小写字母和"-"、"\_"、"."三个特殊字符，但是不能以特殊字符作为首尾字符，命名规范为：^\[a-zA-Z0-9\]+$\|^\[a-zA-Z0-9\]\[a-zA-Z0-9\_-.\]\*\[a-zA-Z0-9\]$。 | +| service\_description.name | - | - | 是 | 微服务名 | 应确保app内部唯一。微服务名支持数字、大小写字母和"-"、"\_"、"."三个特殊字符，但是不能以特殊字符作为首尾字符，命名规范为：^\[a-zA-Z0-9\]+$^\[a-zA-Z0-9\]\[a-zA-Z0-9\_-.\]\*\[a-zA-Z0-9\]$。 | Review comment: Can you change en_US too? This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] weichao666 opened a new pull request #35: modify table Regular expression
weichao666 opened a new pull request #35: modify table Regular expression URL: https://github.com/apache/incubator-servicecomb-docs/pull/35 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[incubator-servicecomb-website] branch asf-site updated: Publish the website
This is an automated email from the ASF dual-hosted git repository.
ningjiang pushed a commit to branch asf-site
in repository
https://gitbox.apache.org/repos/asf/incubator-servicecomb-website.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 44bb2b9 Publish the website
44bb2b9 is described below
commit 44bb2b919f66524b73ded0200bae4b7b489458ed
Author: Willem Jiang
AuthorDate: Mon Aug 20 11:04:09 2018 +0800
Publish the website
---
content/cn/docs/release_note_1_0_0.html | 11 +++
content/cn/index.html | 4 ++--
content/feed.xml| 14 --
3 files changed, 25 insertions(+), 4 deletions(-)
diff --git a/content/cn/docs/release_note_1_0_0.html
b/content/cn/docs/release_note_1_0_0.html
index 58804f0..4ca3b60 100644
--- a/content/cn/docs/release_note_1_0_0.html
+++ b/content/cn/docs/release_note_1_0_0.html
@@ -560,6 +560,17 @@
优化前端界面UI，提供更多功能及提升易用性
+下载地址：
+
+Java-chassis:
+
+http://apache.org/dyn/closer.cgi/incubator/servicecomb/incubator-servicecomb-java-chassis/1.0.0/;>http://apache.org/dyn/closer.cgi/incubator/servicecomb/incubator-servicecomb-java-chassis/1.0.0/
+
+Service-Center:
+
+http://apache.org/dyn/closer.cgi/incubator/servicecomb/incubator-servicecomb-service-center/1.0.0/;>http://apache.org/dyn/closer.cgi/incubator/servicecomb/incubator-servicecomb-service-center/1.0.0/
+
+
diff --git a/content/cn/index.html b/content/cn/index.html
index 539fb41..7465427 100644
--- a/content/cn/index.html
+++ b/content/cn/index.html
@@ -293,8 +293,8 @@
最新新闻
- 微服务 Meetup：Apache
ServiceComb (incubating) Day 演讲资料 ServiceComb 第一个Apache孵化版本发布了！ 号外：现在ServiceComb提供了微服务场景下的数据一致性解决方案Saga！
https://gitter.im/ServiceCombUsers/Lobby;>Join us at
Gitter
- Java-Chassis 发布最新版
1.0.0 Service-Center 发布最新版 1.0.0
Saga releases 发布最新版 0.2.0
https://www.youtube.com/watch?v=yrAneJvVC7A;>这个视频演示了如何Service-Center前端直接从浏览器测试已注册的微服务
+ [里程碑]Apache ServiceComb
1.0.0版本正式发布 微服务 Meetup：Apache ServiceComb
(incubating) Day 演讲资料 https://gitter.im/ServiceCombUsers/Lobby;>Join us at Gitter
+ Saga releases 发布最新版 0.2.0
号外：现在ServiceComb提供了微服务场景下的数据一致性解决方案Saga！
https://www.youtube.com/watch?v=yrAneJvVC7A;>这个视频演示了如何Service-Center前端直接从浏览器测试已注册的微服务
diff --git a/content/feed.xml b/content/feed.xml
index f55805d..930f566 100644
--- a/content/feed.xml
+++ b/content/feed.xml
@@ -1,4 +1,4 @@
-http://www.w3.org/2005/Atom; >https://jekyllrb.com/;
version="3.4.3">Jekyll2018-08-13T22:41:25+08:00/Apache ServiceComb (incubating)The homepage of
ServiceComb{name=nil,
avatar= [...]
+http://www.w3.org/2005/Atom; >https://jekyllrb.com/;
version="3.4.3">Jekyll2018-08-20T11:03:18+08:00/Apache ServiceComb (incubating)The homepage of
ServiceComb{name=nil,
avatar= [...]
h2 id=java-chassisJava-chassis/h2
@@ -183,7 +183,17 @@
li提升ETCD链接的弹性伸缩能力和自我修复能力/li
liService-Center 支持在多基础设施中部署/li
li优化前端界面UI，提供更多功能及提升易用性/li
-/ulWang
Qilinwangqilint...@gmail.comhttps://github.com/wangkirinServieComb版本正式步入稳定态Consul Service Mesh实战2018-07-21T00:00:00+08:00http://apache.org/dyn/closer.cgi/incubator/servicecomb/incubator-servicecomb-java-chassis/1.0.0/http://apache.org/dyn/closer.cgi/incubator/servicecomb/incubator-servicecomb-java-chassis/1.0.0//a/p;
+
+pService-Center:/p
+
+pa
href=http://apache.org/dyn/closer.cgi/incubator/servicecomb/incubator-servicecomb-service-center/1.0.0/http://apache.org/dyn/closer.cgi/incubator/servicecomb/incubator-servicecomb-service-center/1.0.0//a/p;Wang
Qilinwangqilint...@gmail.comhttps://github.com/wangkirinServieComb版本正式步入稳 [...]
p在最近发布的a
href=https://github.com/hashicorp/consul/releasesConsul1.2/a中，a
href=https://www.hashicorp.com/HashiCorp/a宣布支持Service
Mesh。作为一个优秀的分布式服务发现解决方案，Consul是如何支持Service Mesh的呢？本文将带读者一探究竟。/p
[incubator-servicecomb-website] branch asf-site updated (6c6887a -> 2fa73cc)
This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a change to branch asf-site in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-website.git. from 6c6887a Publish the website add db91880 edit homepage latest news & add github link new 2fa73cc Merge branch 'master' into asf-site The 1 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: _pages/cn/home.md | 14 -- _posts/cn/2018-8-13-1.0.0-release-note.md | 15 ++- 2 files changed, 18 insertions(+), 11 deletions(-) mode change 100644 => 100755 _pages/cn/home.md
[incubator-servicecomb-website] 01/01: Merge branch 'master' into asf-site
This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-website.git commit 2fa73cc906b0c5e5cf1ce79138b1ef90929358dc Merge: 6c6887a db91880 Author: Willem Jiang AuthorDate: Mon Aug 20 11:02:59 2018 +0800 Merge branch 'master' into asf-site _pages/cn/home.md | 14 -- _posts/cn/2018-8-13-1.0.0-release-note.md | 15 ++- 2 files changed, 18 insertions(+), 11 deletions(-)
[GitHub] Gannalyo opened a new issue #257: An unusual problem for SagaEndedEvet
Gannalyo opened a new issue #257: An unusual problem for SagaEndedEvet URL: https://github.com/apache/incubator-servicecomb-saga/issues/257 Yesterday, it's very accurately to the data of the table 'txevent'. However, the 'creationTime' to 'SagaEndedEvent' were changed when I started the Alpha program. In fact, it had happened many times before. I apologize to this problem due to I didn't know how to make it happen again. Please pay attention to it. Thank you so much!  This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] WillemJiang closed pull request #131: edit homepage latest news & add github link
WillemJiang closed pull request #131: edit homepage latest news & add github link URL: https://github.com/apache/incubator-servicecomb-website/pull/131 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull request (from a fork), the diff is supplied below (as it won't show otherwise due to GitHub magic): diff --git a/_pages/cn/home.md b/_pages/cn/home.md old mode 100644 new mode 100755 index 1b470108..37f79359 --- a/_pages/cn/home.md +++ b/_pages/cn/home.md @@ -22,13 +22,10 @@ intro: -微服务 Meetup：Apache ServiceComb (incubating) Day 演讲资料 - - -ServiceComb 第一个Apache孵化版本发布了！ +[里程碑]Apache ServiceComb 1.0.0版本正式发布 -号外：现在ServiceComb提供了微服务场景下的数据一致性解决方案Saga！ +微服务 Meetup：Apache ServiceComb (incubating) Day 演讲资料 Join us at Gitter @@ -37,13 +34,10 @@ intro: -Java-Chassis 发布最新版 1.0.0 - - -Service-Center 发布最新版 1.0.0 +Saga releases 发布最新版 0.2.0 -Saga releases 发布最新版 0.2.0 +号外：现在ServiceComb提供了微服务场景下的数据一致性解决方案Saga！ 这个视频演示了如何Service-Center前端直接从浏览器测试已注册的微服务 diff --git a/_posts/cn/2018-8-13-1.0.0-release-note.md b/_posts/cn/2018-8-13-1.0.0-release-note.md index 23b80c4c..7cc4e562 100755 --- a/_posts/cn/2018-8-13-1.0.0-release-note.md +++ b/_posts/cn/2018-8-13-1.0.0-release-note.md @@ -134,4 +134,17 @@ redirect_from: - 服务依赖管理采用事件驱动机制 - 提升ETCD链接的弹性伸缩能力和自我修复能力 - Service-Center 支持在多基础设施中部署 -- 优化前端界面UI，提供更多功能及提升易用性 \ No newline at end of file +- 优化前端界面UI，提供更多功能及提升易用性 + + +## 下载地址： + +Java-chassis: + +[http://apache.org/dyn/closer.cgi/incubator/servicecomb/incubator-servicecomb-java-chassis/1.0.0/](http://apache.org/dyn/closer.cgi/incubator/servicecomb/incubator-servicecomb-java-chassis/1.0.0/) + +Service-Center: + +[http://apache.org/dyn/closer.cgi/incubator/servicecomb/incubator-servicecomb-service-center/1.0.0/](http://apache.org/dyn/closer.cgi/incubator/servicecomb/incubator-servicecomb-service-center/1.0.0/) + + This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[incubator-servicecomb-website] branch master updated: edit homepage latest news & add github link
This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-website.git The following commit(s) were added to refs/heads/master by this push: new db91880 edit homepage latest news & add github link db91880 is described below commit db91880dca51864d216b0ca510ba0419398d6b74 Author: Wang Kirin AuthorDate: Tue Aug 14 15:15:44 2018 +0800 edit homepage latest news & add github link Signed-off-by: Wang Kirin --- _pages/cn/home.md | 14 -- _posts/cn/2018-8-13-1.0.0-release-note.md | 15 ++- 2 files changed, 18 insertions(+), 11 deletions(-) diff --git a/_pages/cn/home.md b/_pages/cn/home.md old mode 100644 new mode 100755 index 1b47010..37f7935 --- a/_pages/cn/home.md +++ b/_pages/cn/home.md @@ -22,13 +22,10 @@ intro: -微服务 Meetup：Apache ServiceComb (incubating) Day 演讲资料 - - -ServiceComb 第一个Apache孵化版本发布了！ +[里程碑]Apache ServiceComb 1.0.0版本正式发布 -号外：现在ServiceComb提供了微服务场景下的数据一致性解决方案Saga！ +微服务 Meetup：Apache ServiceComb (incubating) Day 演讲资料 Join us at Gitter @@ -37,13 +34,10 @@ intro: -Java-Chassis 发布最新版 1.0.0 - - -Service-Center 发布最新版 1.0.0 +Saga releases 发布最新版 0.2.0 -Saga releases 发布最新版 0.2.0 +号外：现在ServiceComb提供了微服务场景下的数据一致性解决方案Saga！ 这个视频演示了如何Service-Center前端直接从浏览器测试已注册的微服务 diff --git a/_posts/cn/2018-8-13-1.0.0-release-note.md b/_posts/cn/2018-8-13-1.0.0-release-note.md index 23b80c4..7cc4e56 100755 --- a/_posts/cn/2018-8-13-1.0.0-release-note.md +++ b/_posts/cn/2018-8-13-1.0.0-release-note.md @@ -134,4 +134,17 @@ redirect_from: - 服务依赖管理采用事件驱动机制 - 提升ETCD链接的弹性伸缩能力和自我修复能力 - Service-Center 支持在多基础设施中部署 -- 优化前端界面UI，提供更多功能及提升易用性 \ No newline at end of file +- 优化前端界面UI，提供更多功能及提升易用性 + + +## 下载地址： + +Java-chassis: + +[http://apache.org/dyn/closer.cgi/incubator/servicecomb/incubator-servicecomb-java-chassis/1.0.0/](http://apache.org/dyn/closer.cgi/incubator/servicecomb/incubator-servicecomb-java-chassis/1.0.0/) + +Service-Center: + +[http://apache.org/dyn/closer.cgi/incubator/servicecomb/incubator-servicecomb-service-center/1.0.0/](http://apache.org/dyn/closer.cgi/incubator/servicecomb/incubator-servicecomb-service-center/1.0.0/) + +
[GitHub] wujimin opened a new pull request #878: [SCB-854] BootListener support load by not only spring bean, but also SPI
wujimin opened a new pull request #878: [SCB-854] BootListener support load by not only spring bean, but also SPI URL: https://github.com/apache/incubator-servicecomb-java-chassis/pull/878 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] coveralls commented on issue #256: SCB-853 Rewrite the lamda function in saga-core to support JDK 7
coveralls commented on issue #256: SCB-853 Rewrite the lamda function in saga-core to support JDK 7 URL: https://github.com/apache/incubator-servicecomb-saga/pull/256#issuecomment-414180455 [](https://coveralls.io/builds/18562400) Coverage decreased (-0.9%) to 93.625% when pulling **ce83f17b89dcdf013961f713d62dcd452aa4420e on SCB-853** into **66344e7339eaef597442594ce7fa9fc828e1ffe9 on master**. This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] wangkirin opened a new pull request #131: edit homepage latest news & add github link
wangkirin opened a new pull request #131: edit homepage latest news & add github link URL: https://github.com/apache/incubator-servicecomb-website/pull/131 Signed-off-by: Wang Kirin This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] coveralls commented on issue #255: SCB-852 Create saga-core-akka module
coveralls commented on issue #255: SCB-852 Create saga-core-akka module URL: https://github.com/apache/incubator-servicecomb-saga/pull/255#issuecomment-414178861 [](https://coveralls.io/builds/18562321) Coverage decreased (-0.2%) to 94.239% when pulling **d847a1a4d81a0ac11522638c16ea11686d4c4e52 on SCB-852** into **66344e7339eaef597442594ce7fa9fc828e1ffe9 on master**. This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] WillemJiang opened a new pull request #256: SCB-853 Rewrite the lamda function in saga-core to support JDK 7
WillemJiang opened a new pull request #256: SCB-853 Rewrite the lamda function in saga-core to support JDK 7 URL: https://github.com/apache/incubator-servicecomb-saga/pull/256 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[incubator-servicecomb-saga] 01/01: SCB-853 Saga-core noew supports JDK7
This is an automated email from the ASF dual-hosted git repository.
ningjiang pushed a commit to branch SCB-853
in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git
commit ce83f17b89dcdf013961f713d62dcd452aa4420e
Author: Willem Jiang
AuthorDate: Mon Aug 20 09:30:14 2018 +0800
SCB-853 Saga-core noew supports JDK7
---
saga-core/pom.xml | 10
.../servicecomb/saga/core/BackwardRecovery.java| 5 ++
.../apache/servicecomb/saga/core/Compensation.java | 32 +--
.../saga/core/CompositeSagaResponse.java | 31 ---
.../apache/servicecomb/saga/core/Descriptive.java | 4 +-
.../org/apache/servicecomb/saga/core/Fallback.java | 17 +-
.../servicecomb/saga/core/ForwardRecovery.java | 5 ++
.../servicecomb/saga/core/GraphBasedSaga.java | 15 +++---
.../saga/core/LoggingRecoveryPolicy.java | 5 ++
.../servicecomb/saga/core/NoOpSagaRequest.java | 6 +++
.../apache/servicecomb/saga/core/Operation.java| 8 +--
.../servicecomb/saga/core/RestOperation.java | 14 +++--
.../apache/servicecomb/saga/core/SagaContext.java | 4 +-
.../servicecomb/saga/core/SagaContextImpl.java | 35 +++-
.../apache/servicecomb/saga/core/SagaEvent.java| 5 ++
.../apache/servicecomb/saga/core/SagaRequest.java | 6 +--
.../servicecomb/saga/core/SagaTaskFactory.java | 10 ++--
.../apache/servicecomb/saga/core/Transaction.java | 18 +++
.../servicecomb/saga/core/TransactionConsumer.java | 5 ++
.../saga/core/dag/ByLevelTraveller.java| 5 +-
.../saga/core/dag/GraphBasedSagaFactory.java | 3 +-
.../servicecomb/saga/core/dag/GraphBuilder.java| 9 ++--
.../saga/core/dag/GraphCycleDetectorImpl.java | 26 +
.../org/apache/servicecomb/saga/core/dag/Node.java | 4 +-
.../servicecomb/saga/core/CompensationImpl.java| 5 ++
.../saga/core/CompositeSagaResponseTest.java | 8 +++
.../servicecomb/saga/core/ForwardRecoveryTest.java | 7 ++-
.../servicecomb/saga/core/RestOperationTest.java | 18 ---
.../servicecomb/saga/core/RetrySagaLogTest.java| 19 +--
.../saga/core/SagaExecutionComponentTestBase.java | 44 +++
.../servicecomb/saga/core/SagaIntegrationTest.java | 63 ++
.../dag/DirectedAcyclicGraphTraversalTest.java | 4 +-
.../saga/core/dag/GraphBuilderTest.java| 40 --
.../saga/core/dag/GraphCycleDetectorTest.java | 3 +-
.../servicecomb/saga/format/JacksonFallback.java | 11
35 files changed, 366 insertions(+), 138 deletions(-)
diff --git a/saga-core/pom.xml b/saga-core/pom.xml
index fd1b47c..e460b1a 100644
--- a/saga-core/pom.xml
+++ b/saga-core/pom.xml
@@ -95,6 +95,16 @@
+
+org.apache.maven.plugins
+maven-compiler-plugin
+3.1
+
+ UTF-8
+ 1.7
+ 1.7
+
+
diff --git
a/saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java
b/saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java
index e46de2f..799dbbf 100644
---
a/saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java
+++
b/saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java
@@ -46,4 +46,9 @@ public class BackwardRecovery implements RecoveryPolicy {
throw e;
}
}
+
+ @Override
+ public String description() {
+return getClass().getSimpleName();
+ }
}
diff --git
a/saga-core/src/main/java/org/apache/servicecomb/saga/core/Compensation.java
b/saga-core/src/main/java/org/apache/servicecomb/saga/core/Compensation.java
index f642011..a6a352b 100644
--- a/saga-core/src/main/java/org/apache/servicecomb/saga/core/Compensation.java
+++ b/saga-core/src/main/java/org/apache/servicecomb/saga/core/Compensation.java
@@ -20,14 +20,40 @@ package org.apache.servicecomb.saga.core;
public interface Compensation extends Operation {
Compensation SAGA_START_COMPENSATION = new Compensation() {
+@Override
+public SagaResponse send(String address) {
+ return SUCCESSFUL_SAGA_RESPONSE;
+}
+
+@Override
+public SagaResponse send(String address, SagaResponse response) {
+ return send(address);
+}
+
+@Override
+public int retries() {
+ return DEFAULT_RETRIES;
+}
};
Compensation SAGA_END_COMPENSATION = new Compensation() {
+@Override
+public SagaResponse send(String address) {
+ return SUCCESSFUL_SAGA_RESPONSE;
+}
+
+@Override
+public SagaResponse send(String address, SagaResponse response) {
+ return send(address);
+}
+
+@Override
+public int retries() {
+ return DEFAULT_RETRIES;
+}
};
int DEFAULT_RETRIES = 3;
- default int retries() {
-return DEFAULT_RETRIES;
- }
+ int retries();
}
diff --git
[incubator-servicecomb-saga] branch SCB-853 updated (249e005 -> ce83f17)
This is an automated email from the ASF dual-hosted git repository.
ningjiang pushed a change to branch SCB-853
in repository
https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git.
discard 249e005 SCB-853 Saga-core noew supports JDK7
add d847a1a SCB-852 Added the uncommitted pom of saga-core-akka
new ce83f17 SCB-853 Saga-core noew supports JDK7
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (249e005)
\
N -- N -- N refs/heads/SCB-853 (ce83f17)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 1 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-core => saga-core-akka}/pom.xml | 65 ---
1 file changed, 37 insertions(+), 28 deletions(-)
copy {saga-core => saga-core-akka}/pom.xml (70%)
[incubator-servicecomb-saga] branch SCB-852 updated: SCB-852 Added the uncommitted pom of saga-core-akka
This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch SCB-852 in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git The following commit(s) were added to refs/heads/SCB-852 by this push: new d847a1a SCB-852 Added the uncommitted pom of saga-core-akka d847a1a is described below commit d847a1a4d81a0ac11522638c16ea11686d4c4e52 Author: Willem Jiang AuthorDate: Mon Aug 20 09:53:39 2018 +0800 SCB-852 Added the uncommitted pom of saga-core-akka --- saga-core-akka/pom.xml | 120 + 1 file changed, 120 insertions(+) diff --git a/saga-core-akka/pom.xml b/saga-core-akka/pom.xml new file mode 100644 index 000..a019a25 --- /dev/null +++ b/saga-core-akka/pom.xml @@ -0,0 +1,120 @@ + + + +http://maven.apache.org/POM/4.0.0; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd;> + +saga +org.apache.servicecomb.saga +0.3.0-SNAPSHOT + + 4.0.0 + + saga-core-akka + Saga::Core::Akka + + + + com.lmax + disruptor + + + org.slf4j + slf4j-api + + + org.apache.logging.log4j + log4j-slf4j-impl + + + org.apache.logging.log4j + log4j-api + + + org.apache.logging.log4j + log4j-core + + + org.apache.servicecomb.saga + saga-core + + + com.typesafe.akka + akka-actor_2.12 + + + com.typesafe.akka + akka-slf4j_2.12 + + + io.kamon + kamon-core_2.12 + + + io.kamon + kamon-annotation_2.12 + + + + + com.typesafe.akka + akka-testkit_2.12 + + + org.scalatest + scalatest_2.12 + + + junit + junit + + + org.hamcrest + hamcrest-all + + + org.mockito + mockito-core + + 1.10.19 + + + org.apache.commons + commons-lang3 + + + org.awaitility + awaitility + + + com.github.seanyinx + unit-scaffolding + + + org.apache.servicecomb.saga + saga-core + test-jar + 0.3.0-SNAPSHOT + test + + + org.apache.servicecomb.saga + saga-core + + + +
[incubator-servicecomb-saga] 01/01: SCB-853 Saga-core noew supports JDK7
This is an automated email from the ASF dual-hosted git repository.
ningjiang pushed a commit to branch SCB-853
in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git
commit 249e00574a2f10ec7b570a94d9432fcf9959be37
Author: Willem Jiang
AuthorDate: Mon Aug 20 09:30:14 2018 +0800
SCB-853 Saga-core noew supports JDK7
---
saga-core/pom.xml | 10
.../servicecomb/saga/core/BackwardRecovery.java| 5 ++
.../apache/servicecomb/saga/core/Compensation.java | 32 +--
.../saga/core/CompositeSagaResponse.java | 31 ---
.../apache/servicecomb/saga/core/Descriptive.java | 4 +-
.../org/apache/servicecomb/saga/core/Fallback.java | 17 +-
.../servicecomb/saga/core/ForwardRecovery.java | 5 ++
.../servicecomb/saga/core/GraphBasedSaga.java | 15 +++---
.../saga/core/LoggingRecoveryPolicy.java | 5 ++
.../servicecomb/saga/core/NoOpSagaRequest.java | 6 +++
.../apache/servicecomb/saga/core/Operation.java| 8 +--
.../servicecomb/saga/core/RestOperation.java | 14 +++--
.../apache/servicecomb/saga/core/SagaContext.java | 4 +-
.../servicecomb/saga/core/SagaContextImpl.java | 35 +++-
.../apache/servicecomb/saga/core/SagaEvent.java| 5 ++
.../apache/servicecomb/saga/core/SagaRequest.java | 6 +--
.../servicecomb/saga/core/SagaTaskFactory.java | 10 ++--
.../apache/servicecomb/saga/core/Transaction.java | 18 +++
.../servicecomb/saga/core/TransactionConsumer.java | 5 ++
.../saga/core/dag/ByLevelTraveller.java| 5 +-
.../saga/core/dag/GraphBasedSagaFactory.java | 3 +-
.../servicecomb/saga/core/dag/GraphBuilder.java| 9 ++--
.../saga/core/dag/GraphCycleDetectorImpl.java | 26 +
.../org/apache/servicecomb/saga/core/dag/Node.java | 4 +-
.../servicecomb/saga/core/CompensationImpl.java| 5 ++
.../saga/core/CompositeSagaResponseTest.java | 8 +++
.../servicecomb/saga/core/ForwardRecoveryTest.java | 7 ++-
.../servicecomb/saga/core/RestOperationTest.java | 18 ---
.../servicecomb/saga/core/RetrySagaLogTest.java| 19 +--
.../saga/core/SagaExecutionComponentTestBase.java | 44 +++
.../servicecomb/saga/core/SagaIntegrationTest.java | 63 ++
.../dag/DirectedAcyclicGraphTraversalTest.java | 4 +-
.../saga/core/dag/GraphBuilderTest.java| 40 --
.../saga/core/dag/GraphCycleDetectorTest.java | 3 +-
.../servicecomb/saga/format/JacksonFallback.java | 11
35 files changed, 366 insertions(+), 138 deletions(-)
diff --git a/saga-core/pom.xml b/saga-core/pom.xml
index fd1b47c..e460b1a 100644
--- a/saga-core/pom.xml
+++ b/saga-core/pom.xml
@@ -95,6 +95,16 @@
+
+org.apache.maven.plugins
+maven-compiler-plugin
+3.1
+
+ UTF-8
+ 1.7
+ 1.7
+
+
diff --git
a/saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java
b/saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java
index e46de2f..799dbbf 100644
---
a/saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java
+++
b/saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java
@@ -46,4 +46,9 @@ public class BackwardRecovery implements RecoveryPolicy {
throw e;
}
}
+
+ @Override
+ public String description() {
+return getClass().getSimpleName();
+ }
}
diff --git
a/saga-core/src/main/java/org/apache/servicecomb/saga/core/Compensation.java
b/saga-core/src/main/java/org/apache/servicecomb/saga/core/Compensation.java
index f642011..a6a352b 100644
--- a/saga-core/src/main/java/org/apache/servicecomb/saga/core/Compensation.java
+++ b/saga-core/src/main/java/org/apache/servicecomb/saga/core/Compensation.java
@@ -20,14 +20,40 @@ package org.apache.servicecomb.saga.core;
public interface Compensation extends Operation {
Compensation SAGA_START_COMPENSATION = new Compensation() {
+@Override
+public SagaResponse send(String address) {
+ return SUCCESSFUL_SAGA_RESPONSE;
+}
+
+@Override
+public SagaResponse send(String address, SagaResponse response) {
+ return send(address);
+}
+
+@Override
+public int retries() {
+ return DEFAULT_RETRIES;
+}
};
Compensation SAGA_END_COMPENSATION = new Compensation() {
+@Override
+public SagaResponse send(String address) {
+ return SUCCESSFUL_SAGA_RESPONSE;
+}
+
+@Override
+public SagaResponse send(String address, SagaResponse response) {
+ return send(address);
+}
+
+@Override
+public int retries() {
+ return DEFAULT_RETRIES;
+}
};
int DEFAULT_RETRIES = 3;
- default int retries() {
-return DEFAULT_RETRIES;
- }
+ int retries();
}
diff --git
[incubator-servicecomb-saga] branch SCB-853 created (now 249e005)
This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a change to branch SCB-853 in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git. at 249e005 SCB-853 Saga-core noew supports JDK7 This branch includes the following new commits: new 249e005 SCB-853 Saga-core noew supports JDK7 The 1 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.
[incubator-servicecomb-saga] branch SCB-852 updated: SCB-852 Fixed the build error by adding saga-core-akka module
This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch SCB-852 in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git The following commit(s) were added to refs/heads/SCB-852 by this push: new 02950ca SCB-852 Fixed the build error by adding saga-core-akka module 02950ca is described below commit 02950ca271c6df74b39b3319118bd27319e3835e Author: Willem Jiang AuthorDate: Mon Aug 20 08:40:02 2018 +0800 SCB-852 Fixed the build error by adding saga-core-akka module --- pom.xml | 1 + 1 file changed, 1 insertion(+) diff --git a/pom.xml b/pom.xml index 542fb1c..83e5366 100644 --- a/pom.xml +++ b/pom.xml @@ -32,6 +32,7 @@ saga-core +saga-core-akka transports saga-spring docker-build-config
[GitHub] wujimin commented on a change in pull request #876: [SCB-849] refactor producer connection limit using vertx metrics spi mechanism
wujimin commented on a change in pull request #876: [SCB-849] refactor producer
connection limit using vertx metrics spi mechanism
URL:
https://github.com/apache/incubator-servicecomb-java-chassis/pull/876#discussion_r211121021
##
File path:
foundations/foundation-vertx/src/main/java/org/apache/servicecomb/foundation/vertx/metrics/SCBHttpServerMetrics.java
##
@@ -0,0 +1,53 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.servicecomb.foundation.vertx.metrics;
+
+import java.util.concurrent.atomic.AtomicInteger;
+
+import org.apache.servicecomb.foundation.common.event.EventManager;
+import org.apache.servicecomb.foundation.vertx.ClientEvent;
+import org.apache.servicecomb.foundation.vertx.ConnectionEvent;
+import org.apache.servicecomb.foundation.vertx.TransportType;
+
+import io.vertx.core.metrics.impl.DummyVertxMetrics.DummyHttpServerMetrics;
+import io.vertx.core.net.SocketAddress;
+
+public class SCBHttpServerMetrics extends DummyHttpServerMetrics {
+
+ private final AtomicInteger connectedCounter = new AtomicInteger();
+
+ public AtomicInteger getConnectedCounter() {
+return connectedCounter;
+ }
+
+ @Override
+ public Void connected(SocketAddress remoteAddress, String remoteName) {
+int connectedCount = connectedCounter.incrementAndGet();
+EventManager.post(new ClientEvent(remoteAddress.toString(),
Review comment:
it's a client event?
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] WillemJiang commented on issue #253: when AbortEvent is late
WillemJiang commented on issue #253: when AbortEvent is late URL: https://github.com/apache/incubator-servicecomb-saga/issues/253#issuecomment-414160559 @HuZheting Thanks for pointing that out, it's the issue that we are facing now. Now we are thinking to updated the Alpha to react the TxAbortedEvent directly, and we can get rid off the complex SQL. This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] HuZheting commented on issue #253: when AbortEvent is late
HuZheting commented on issue #253: when AbortEvent is late URL: https://github.com/apache/incubator-servicecomb-saga/issues/253#issuecomment-414131553 and in the first test "blockingStub.onTxEvent(someGrpcEvent(TxAbortedEvent, sagaGlobalId, anotheEntryLocalId));" should be "blockingStub.onTxEvent(someGrpcEvent(TxAbortedEvent, sagaGlobalId, localIdEntry));" I am sorry. just look at the saga-spring-demo example. This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] HuZheting edited a comment on issue #253: when AbortEvent is late
HuZheting edited a comment on issue #253: when AbortEvent is late
URL:
https://github.com/apache/incubator-servicecomb-saga/issues/253#issuecomment-414130629
what I mean is that the bigger surrogateId will update the variable
"nextEndedEventId" and alpha cannot find the smaller one.
>
eventRepository.findFirstUncompensatedEventByIdGreaterThan(nextEndedEventId,
TxEndedEvent.name())
.forEach(event -> {
LOG.info("Found uncompensated event {}", event);
nextEndedEventId = event.id();
commandRepository.saveCompensationCommands(event.globalTxId());
});
@Query("SELECT t FROM TxEvent t "
+ "WHERE t.type = ?1 AND t.surrogateId > ?2 AND EXISTS ( "
+ " SELECT t1.globalTxId FROM TxEvent t1 "
+ " WHERE t1.globalTxId = t.globalTxId "
+ "AND t1.type = 'TxAbortedEvent' AND NOT EXISTS ( "
+ "SELECT t2.globalTxId FROM TxEvent t2 "
+ "WHERE t2.globalTxId = t1.globalTxId "
+ " AND t2.localTxId = t1.localTxId "
+ " AND t2.type = 'TxStartedEvent' "
+ " AND t2.creationTime > t1.creationTime)) AND NOT EXISTS ( "
+ " SELECT t3.globalTxId FROM TxEvent t3 "
+ " WHERE t3.globalTxId = t.globalTxId "
+ "AND t3.localTxId = t.localTxId "
+ "AND t3.type = 'TxCompensatedEvent') AND ( "
+ " SELECT MIN(t4.retries) FROM TxEvent t4 "
+ " WHERE t4.globalTxId = t.globalTxId "
+ "AND t4.localTxId = t.localTxId "
+ "AND t4.type = 'TxStartedEvent' ) = 0 "
+ "ORDER BY t.surrogateId ASC")
List findFirstByTypeAndSurrogateIdGreaterThan(String type, long
surrogateId, Pageable pageable);
Take the saga-spring-demo as example.
There are two request at the same time. They firstly invoke the car service
and succeed. Then they invoke the hotel service，but the hotel service fail.
if we can't ensure the order of message of two different invocations, Alpha
may receive messages in the following order：
https://user-images.githubusercontent.com/9289881/44309435-294e9480-a3f9-11e8-8755-cdfb02d6bd66.png;>
`
String sagaGlobalId = UUID.randomUUID().toString(); //Request1
String bookingApplicationLocalId = UUID.randomUUID().toString();
String carServiceLocalId = UUID.randomUUID().toString();
String hotelServiceLocalId = UUID.randomUUID().toString();
String anotherSagaGlobalId = UUID.randomUUID().toString();//Request2
String anotheBookingApplicationLocalId = UUID.randomUUID().toString();
String anotherCarServiceLocalId = UUID.randomUUID().toString();
String anotherHoterServceiLocalId = UUID.randomUUID().toString();
asyncStub.onConnected(serviceConfig, compensateResponseObserver);
blockingStub.onTxEvent(someGrpcEvent(SagaStartedEvent, sagaGlobalId,
bookingApplicationLocalId));
blockingStub.onTxEvent(someGrpcEvent(SagaEndedEvent,
anotherSagaGlobalId, anotheBookingApplicationLocalId));
blockingStub.onTxEvent(someGrpcEvent(TxStartedEvent, sagaGlobalId,
carServiceLocalId));
blockingStub.onTxEvent(someGrpcEvent(TxEndedEvent, sagaGlobalId,
carServiceLocalId));
//surrogateId --> 4
blockingStub.onTxEvent(someGrpcEvent(TxStartedEvent,
anotherSagaGlobalId, anotherCarServiceLocalId));
blockingStub.onTxEvent(someGrpcEvent(TxEndedEvent, anotherSagaGlobalId,
anotherCarServiceLocalId));
//surrogateId --> 6
blockingStub.onTxEvent(someGrpcEvent(TxStartedEvent, sagaGlobalId,
hotelServiceLocalId));
blockingStub.onTxEvent(someGrpcEvent(TxStartedEvent,
anotherSagaGlobalId, anotherHoterServceiLocalId));
//the latter hotelservice abort event come first
blockingStub.onTxEvent(someGrpcEvent(TxAbortedEvent,
anotherSagaGlobalId, anotherHoterServceiLocalId));
await().atMost(2, SECONDS).until(() -> !receivedCommands.isEmpty());
assertThat(receivedCommands.poll().getGlobalTxId(),
is(anotherSagaGlobalId));
//the TxAbortedEvent of the first hotelservice TxAbortedEvent didn't
come until the previous TxAbortedEvent has been found
blockingStub.onTxEvent(someGrpcEvent(TxAbortedEvent, sagaGlobalId,
hotelServiceLocalId));
//now, the variable "nextEndedEventId" is 6, so the TxEndedEvent whose
surrogateId is 4 can't be found.
await().atMost(10, SECONDS).until(() -> receivedCommands.size() > 1);
assertThat(receivedCommands.size(), is(2));
`
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] HuZheting commented on issue #253: when AbortEvent is late
HuZheting commented on issue #253: when AbortEvent is late
URL:
https://github.com/apache/incubator-servicecomb-saga/issues/253#issuecomment-414130629
what I mean is that the bigger surrogateId will update the variable
"nextEndedEventId" and alpha cannot find the smaller one.
>
eventRepository.findFirstUncompensatedEventByIdGreaterThan(nextEndedEventId,
TxEndedEvent.name())
.forEach(event -> {
LOG.info("Found uncompensated event {}", event);
nextEndedEventId = event.id();
commandRepository.saveCompensationCommands(event.globalTxId());
});
@Query("SELECT t FROM TxEvent t "
+ "WHERE t.type = ?1 AND t.surrogateId > ?2 AND EXISTS ( "
+ " SELECT t1.globalTxId FROM TxEvent t1 "
+ " WHERE t1.globalTxId = t.globalTxId "
+ "AND t1.type = 'TxAbortedEvent' AND NOT EXISTS ( "
+ "SELECT t2.globalTxId FROM TxEvent t2 "
+ "WHERE t2.globalTxId = t1.globalTxId "
+ " AND t2.localTxId = t1.localTxId "
+ " AND t2.type = 'TxStartedEvent' "
+ " AND t2.creationTime > t1.creationTime)) AND NOT EXISTS ( "
+ " SELECT t3.globalTxId FROM TxEvent t3 "
+ " WHERE t3.globalTxId = t.globalTxId "
+ "AND t3.localTxId = t.localTxId "
+ "AND t3.type = 'TxCompensatedEvent') AND ( "
+ " SELECT MIN(t4.retries) FROM TxEvent t4 "
+ " WHERE t4.globalTxId = t.globalTxId "
+ "AND t4.localTxId = t.localTxId "
+ "AND t4.type = 'TxStartedEvent' ) = 0 "
+ "ORDER BY t.surrogateId ASC")
List findFirstByTypeAndSurrogateIdGreaterThan(String type, long
surrogateId, Pageable pageable);
Take the saga-spring-demo as example.
There are two request at the same time. They firstly invoke the car service
and succeed. Then they invoke the hotel service，but the hotel service fail.
if we can't ensure the order of message of two different invocations, Alpha
may receive messages in the following order：
https://user-images.githubusercontent.com/9289881/44309435-294e9480-a3f9-11e8-8755-cdfb02d6bd66.png;>
`
String sagaGlobalId = UUID.randomUUID().toString(); //Request1
String bookingApplicationLocalId = UUID.randomUUID().toString();
String carServiceLocalId = UUID.randomUUID().toString();
String hotelServiceLocalId = UUID.randomUUID().toString();
String anotherSagaGlobalId = UUID.randomUUID().toString();//Request2
String anotheBookingApplicationLocalId = UUID.randomUUID().toString();
String anotherCarServiceLocalId = UUID.randomUUID().toString();
String anotherHoterServceiLocalId = UUID.randomUUID().toString();
asyncStub.onConnected(serviceConfig, compensateResponseObserver);
blockingStub.onTxEvent(someGrpcEvent(SagaStartedEvent, sagaGlobalId,
bookingApplicationLocalId));
blockingStub.onTxEvent(someGrpcEvent(SagaEndedEvent,
anotherSagaGlobalId, anotheBookingApplicationLocalId));
blockingStub.onTxEvent(someGrpcEvent(TxStartedEvent, sagaGlobalId,
carServiceLocalId));
blockingStub.onTxEvent(someGrpcEvent(TxEndedEvent, sagaGlobalId,
carServiceLocalId));//surrogateId --> 4
blockingStub.onTxEvent(someGrpcEvent(TxStartedEvent,
anotherSagaGlobalId, anotherCarServiceLocalId));
blockingStub.onTxEvent(someGrpcEvent(TxEndedEvent, anotherSagaGlobalId,
anotherCarServiceLocalId));//surrogateId --> 6
blockingStub.onTxEvent(someGrpcEvent(TxStartedEvent, sagaGlobalId,
hotelServiceLocalId));
blockingStub.onTxEvent(someGrpcEvent(TxStartedEvent,
anotherSagaGlobalId, anotherHoterServceiLocalId));
//the latter hotelservice abort event come first
blockingStub.onTxEvent(someGrpcEvent(TxAbortedEvent,
anotherSagaGlobalId, anotherHoterServceiLocalId));
await().atMost(2, SECONDS).until(() -> !receivedCommands.isEmpty());
assertThat(receivedCommands.poll().getGlobalTxId(),
is(anotherSagaGlobalId));
//the TxAbortedEvent of the first hotelservice TxAbortedEvent didn't
come until the previous TxAbortedEvent has been found
blockingStub.onTxEvent(someGrpcEvent(TxAbortedEvent, sagaGlobalId,
hotelServiceLocalId));
//now, the variable "nextEndedEventId" is 6, so the TxEndedEvent whose
surrogateId is 4 can't be found.
await().atMost(10, SECONDS).until(() -> receivedCommands.size() > 1);
assertThat(receivedCommands.size(), is(2));
`
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
