You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicecomb.apache.org by ni...@apache.org on 2019/08/10 07:50:22 UTC
[servicecomb-pack] 17/36: SCB-1411 SagaAbortedEvent persistence add
exception stack information
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/servicecomb-pack.git
commit 031c0b001ab9ee72688a19c67d8e57a98a71dc53
Author: Lei Zhang <co...@gmail.com>
AuthorDate: Fri Aug 9 01:41:40 2019 +0800
SCB-1411 SagaAbortedEvent persistence add exception stack information
---
.../pack/alpha/core/fsm/event/SagaAbortedEvent.java | 17 ++++++++++++++++-
.../pack/alpha/server/fsm/GrpcSagaEventService.java | 3 ++-
2 files changed, 18 insertions(+), 2 deletions(-)
diff --git a/alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/fsm/event/SagaAbortedEvent.java b/alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/fsm/event/SagaAbortedEvent.java
index 8526bad..a36b1b0 100644
--- a/alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/fsm/event/SagaAbortedEvent.java
+++ b/alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/fsm/event/SagaAbortedEvent.java
@@ -22,6 +22,16 @@ import org.apache.servicecomb.pack.alpha.core.fsm.event.base.SagaEvent;
public class SagaAbortedEvent extends SagaEvent {
+ private byte[] payloads;
+
+ public byte[] getPayloads() {
+ return payloads;
+ }
+
+ public void setPayloads(byte[] payloads) {
+ this.payloads = payloads;
+ }
+
public static Builder builder() {
return new Builder();
}
@@ -49,11 +59,16 @@ public class SagaAbortedEvent extends SagaEvent {
return this;
}
- public Builder createTime(Date createTime){
+ public Builder createTime(Date createTime) {
sagaAbortedEvent.setCreateTime(createTime);
return this;
}
+ public Builder payloads(byte[] payloads) {
+ sagaAbortedEvent.setPayloads(payloads);
+ return this;
+ }
+
public SagaAbortedEvent build() {
return sagaAbortedEvent;
}
diff --git a/alpha/alpha-server/src/main/java/org/apache/servicecomb/pack/alpha/server/fsm/GrpcSagaEventService.java b/alpha/alpha-server/src/main/java/org/apache/servicecomb/pack/alpha/server/fsm/GrpcSagaEventService.java
index 4b4e884..9c4dac0 100644
--- a/alpha/alpha-server/src/main/java/org/apache/servicecomb/pack/alpha/server/fsm/GrpcSagaEventService.java
+++ b/alpha/alpha-server/src/main/java/org/apache/servicecomb/pack/alpha/server/fsm/GrpcSagaEventService.java
@@ -98,7 +98,8 @@ public class GrpcSagaEventService extends TxEventServiceImplBase {
event = org.apache.servicecomb.pack.alpha.core.fsm.event.SagaAbortedEvent.builder()
.serviceName(message.getServiceName())
.instanceId(message.getInstanceId())
- .globalTxId(message.getGlobalTxId()).build();
+ .globalTxId(message.getGlobalTxId())
+ .payloads(message.getPayloads().toByteArray()).build();
} else if (message.getType().equals(EventType.SagaTimeoutEvent.name())) {
event = org.apache.servicecomb.pack.alpha.core.fsm.event.SagaTimeoutEvent.builder()
.serviceName(message.getServiceName())