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 <[email protected]> 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())
