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 99e48594d2b539a3f363a85ab997f447951a6c6c
Author: Lei Zhang <zhang...@apache.org>
AuthorDate: Tue Nov 5 23:52:21 2019 +0800
SCB-1508 Add onGetServiceMeta to interface MessageSender
---
.../grpc/core/LoadBalanceSenderAdapter.java | 27 ++++++++++++++++++++++
.../grpc/saga/GrpcSagaClientMessageSender.java | 6 +++++
.../grpc/saga/RetryableMessageSender.java | 6 +++++
.../grpc/tcc/GrpcTccClientMessageSender.java | 5 ++++
.../omega/transaction/spring/MessageConfig.java | 11 +++++++++
omega/omega-transaction/pom.xml | 4 ++++
.../pack/omega/transaction/MessageSender.java | 4 ++++
.../transaction/CompensableInterceptorTest.java | 6 +++++
.../CompensationMessageHandlerTest.java | 6 +++++
.../omega/transaction/DefaultRecoveryTest.java | 6 +++++
.../omega/transaction/ForwardRecoveryTest.java | 6 +++++
.../pack/omega/transaction/SagaEndAspectTest.java | 7 +++++-
.../SagaStartAnnotationProcessorTest.java | 6 +++++
.../omega/transaction/SagaStartAspectTest.java | 6 +++++
.../omega/transaction/TransactionAspectTest.java | 6 +++++
.../tcc/CoordinateMessageHandlerTest.java | 6 +++++
.../transaction/tcc/TccParticipatorAspectTest.java | 6 +++++
.../tcc/TccStartAnnotationProcessorTest.java | 6 +++++
.../omega/transaction/tcc/TccStartAspectTest.java | 6 +++++
.../servicecomb/pack/common/AlphaMetaKeys.java | 22 ++++++++++++++++++
20 files changed, 157 insertions(+), 1 deletion(-)
diff --git
a/omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/core/LoadBalanceSenderAdapter.java
b/omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/core/LoadBalanceSenderAdapter.java
index af3a4a4..8dc77b5 100644
---
a/omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/core/LoadBalanceSenderAdapter.java
+++
b/omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/core/LoadBalanceSenderAdapter.java
@@ -20,6 +20,7 @@ package org.apache.servicecomb.pack.omega.connector.grpc.core;
import com.google.common.base.Optional;
import io.grpc.ManagedChannel;
import java.lang.invoke.MethodHandles;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
import org.apache.servicecomb.pack.omega.transaction.AlphaResponse;
import org.apache.servicecomb.pack.omega.transaction.MessageSender;
import org.apache.servicecomb.pack.omega.transaction.OmegaException;
@@ -85,6 +86,32 @@ public abstract class LoadBalanceSenderAdapter implements
MessageSender {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ boolean metaConsistency = true;
+ ServerMeta serverMeta = null;
+ for (MessageSender sender : loadContext.getSenders().keySet()) {
+ try {
+ if (serverMeta == null) {
+ serverMeta = sender.onGetServerMeta();
+ LOG.info("Alpha configuration is " + serverMeta.getMetaMap());
+ } else {
+ ServerMeta otherServerMeta = sender.onGetServerMeta();
+ if (!serverMeta.getMetaMap().equals(otherServerMeta.getMetaMap())) {
+ metaConsistency = false;
+ LOG.warn("Alpha configuration is " + otherServerMeta.getMetaMap());
+ }
+ }
+ if (!metaConsistency) {
+ throw new Exception("Using different Alpha configuration with
multiple Alpha");
+ }
+ } catch (Exception e) {
+ LOG.error("Failed disconnecting from alpha at {}", sender.target(), e);
+ }
+ }
+ return serverMeta;
+ }
+
+ @Override
public void close() {
loadContext.getPendingTaskRunner().shutdown();
for(ManagedChannel channel : loadContext.getChannels()) {
diff --git
a/omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/saga/GrpcSagaClientMessageSender.java
b/omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/saga/GrpcSagaClientMessageSender.java
index f55634f..2e81ecc 100644
---
a/omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/saga/GrpcSagaClientMessageSender.java
+++
b/omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/saga/GrpcSagaClientMessageSender.java
@@ -19,6 +19,7 @@ package org.apache.servicecomb.pack.omega.connector.grpc.saga;
import com.google.protobuf.ByteString;
import io.grpc.ManagedChannel;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
import
org.apache.servicecomb.pack.omega.connector.grpc.core.LoadBalanceContext;
import org.apache.servicecomb.pack.omega.context.ServiceConfig;
import org.apache.servicecomb.pack.omega.transaction.AlphaResponse;
@@ -76,6 +77,11 @@ public class GrpcSagaClientMessageSender implements
SagaMessageSender {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return blockingEventService.onGetServerMeta(serviceConfig);
+ }
+
+ @Override
public void close() {
// just do nothing here
}
diff --git
a/omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/saga/RetryableMessageSender.java
b/omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/saga/RetryableMessageSender.java
index 275c45a..1149778 100644
---
a/omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/saga/RetryableMessageSender.java
+++
b/omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/saga/RetryableMessageSender.java
@@ -20,6 +20,7 @@ package org.apache.servicecomb.pack.omega.connector.grpc.saga;
import static org.apache.servicecomb.pack.common.EventType.SagaStartedEvent;
import java.util.concurrent.BlockingQueue;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
import org.apache.servicecomb.pack.omega.transaction.AlphaResponse;
import org.apache.servicecomb.pack.omega.transaction.MessageSender;
import org.apache.servicecomb.pack.omega.transaction.OmegaException;
@@ -44,6 +45,11 @@ public class RetryableMessageSender implements
SagaMessageSender {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return null;
+ }
+
+ @Override
public void close() {
}
diff --git
a/omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/tcc/GrpcTccClientMessageSender.java
b/omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/tcc/GrpcTccClientMessageSender.java
index 3acb148..66cfaa8 100644
---
a/omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/tcc/GrpcTccClientMessageSender.java
+++
b/omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/tcc/GrpcTccClientMessageSender.java
@@ -60,6 +60,11 @@ public class GrpcTccClientMessageSender implements
TccMessageSender {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return null;
+ }
+
+ @Override
public void close() {
// do nothing here
}
diff --git
a/omega/omega-spring-tx/src/test/java/org/apache/servicecomb/pack/omega/transaction/spring/MessageConfig.java
b/omega/omega-spring-tx/src/test/java/org/apache/servicecomb/pack/omega/transaction/spring/MessageConfig.java
index d08be21..d18d1bb 100644
---
a/omega/omega-spring-tx/src/test/java/org/apache/servicecomb/pack/omega/transaction/spring/MessageConfig.java
+++
b/omega/omega-spring-tx/src/test/java/org/apache/servicecomb/pack/omega/transaction/spring/MessageConfig.java
@@ -19,6 +19,7 @@ package org.apache.servicecomb.pack.omega.transaction.spring;
import java.util.ArrayList;
import java.util.List;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
import org.apache.servicecomb.pack.omega.context.CallbackContext;
import org.apache.servicecomb.pack.omega.context.IdGenerator;
import org.apache.servicecomb.pack.omega.context.OmegaContext;
@@ -81,6 +82,11 @@ public class MessageConfig {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return null;
+ }
+
+ @Override
public void close() {
}
@@ -111,6 +117,11 @@ public class MessageConfig {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return null;
+ }
+
+ @Override
public void close() {
}
diff --git a/omega/omega-transaction/pom.xml b/omega/omega-transaction/pom.xml
index e9eeb17..fb7e07b 100644
--- a/omega/omega-transaction/pom.xml
+++ b/omega/omega-transaction/pom.xml
@@ -90,6 +90,10 @@
<artifactId>log4j-core</artifactId>
<scope>test</scope>
</dependency>
+ <dependency>
+ <groupId>org.apache.servicecomb.pack</groupId>
+ <artifactId>pack-contract-grpc</artifactId>
+ </dependency>
</dependencies>
</project>
diff --git
a/omega/omega-transaction/src/main/java/org/apache/servicecomb/pack/omega/transaction/MessageSender.java
b/omega/omega-transaction/src/main/java/org/apache/servicecomb/pack/omega/transaction/MessageSender.java
index 9833fdf..20de497 100644
---
a/omega/omega-transaction/src/main/java/org/apache/servicecomb/pack/omega/transaction/MessageSender.java
+++
b/omega/omega-transaction/src/main/java/org/apache/servicecomb/pack/omega/transaction/MessageSender.java
@@ -17,12 +17,16 @@
package org.apache.servicecomb.pack.omega.transaction;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
+
public interface MessageSender {
void onConnected();
void onDisconnected();
+ ServerMeta onGetServerMeta();
+
void close();
String target();
diff --git
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/CompensableInterceptorTest.java
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/CompensableInterceptorTest.java
index 617b4c4..02c2067 100644
---
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/CompensableInterceptorTest.java
+++
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/CompensableInterceptorTest.java
@@ -29,6 +29,7 @@ import java.util.Random;
import java.util.UUID;
import org.apache.servicecomb.pack.common.EventType;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
import org.apache.servicecomb.pack.omega.context.IdGenerator;
import org.apache.servicecomb.pack.omega.context.OmegaContext;
import org.junit.Before;
@@ -52,6 +53,11 @@ public class CompensableInterceptorTest {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return null;
+ }
+
+ @Override
public void close() {
}
diff --git
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/CompensationMessageHandlerTest.java
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/CompensationMessageHandlerTest.java
index 3bc1362..e411f05 100644
---
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/CompensationMessageHandlerTest.java
+++
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/CompensationMessageHandlerTest.java
@@ -27,6 +27,7 @@ import java.util.ArrayList;
import java.util.List;
import org.apache.servicecomb.pack.common.EventType;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
import org.apache.servicecomb.pack.omega.context.CallbackContext;
import org.junit.Before;
import org.junit.Test;
@@ -46,6 +47,11 @@ public class CompensationMessageHandlerTest {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return null;
+ }
+
+ @Override
public void close() {
}
diff --git
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/DefaultRecoveryTest.java
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/DefaultRecoveryTest.java
index 5d76804..6711323 100644
---
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/DefaultRecoveryTest.java
+++
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/DefaultRecoveryTest.java
@@ -35,6 +35,7 @@ import java.util.UUID;
import javax.transaction.InvalidTransactionException;
import org.apache.servicecomb.pack.common.EventType;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
import org.apache.servicecomb.pack.omega.context.IdGenerator;
import org.apache.servicecomb.pack.omega.context.OmegaContext;
import org.apache.servicecomb.pack.omega.transaction.annotations.Compensable;
@@ -79,6 +80,11 @@ public class DefaultRecoveryTest {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return null;
+ }
+
+ @Override
public void close() {
}
diff --git
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/ForwardRecoveryTest.java
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/ForwardRecoveryTest.java
index 7303772..a90b679 100644
---
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/ForwardRecoveryTest.java
+++
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/ForwardRecoveryTest.java
@@ -36,6 +36,7 @@ import java.util.UUID;
import javax.transaction.InvalidTransactionException;
import org.apache.servicecomb.pack.common.EventType;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
import org.apache.servicecomb.pack.omega.context.IdGenerator;
import org.apache.servicecomb.pack.omega.context.OmegaContext;
import org.apache.servicecomb.pack.omega.transaction.annotations.Compensable;
@@ -80,6 +81,11 @@ public class ForwardRecoveryTest {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return null;
+ }
+
+ @Override
public void close() {
}
diff --git
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/SagaEndAspectTest.java
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/SagaEndAspectTest.java
index 6a37f72..d422c30 100644
---
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/SagaEndAspectTest.java
+++
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/SagaEndAspectTest.java
@@ -29,10 +29,10 @@ import java.util.List;
import java.util.UUID;
import org.apache.servicecomb.pack.common.EventType;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
import org.apache.servicecomb.pack.omega.context.IdGenerator;
import org.apache.servicecomb.pack.omega.context.OmegaContext;
import org.apache.servicecomb.pack.omega.context.annotations.SagaEnd;
-import org.apache.servicecomb.pack.omega.context.annotations.SagaStart;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.reflect.MethodSignature;
import org.junit.Before;
@@ -53,6 +53,11 @@ public class SagaEndAspectTest {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return null;
+ }
+
+ @Override
public void close() {
}
diff --git
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/SagaStartAnnotationProcessorTest.java
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/SagaStartAnnotationProcessorTest.java
index 015d2de..b40712d 100644
---
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/SagaStartAnnotationProcessorTest.java
+++
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/SagaStartAnnotationProcessorTest.java
@@ -31,6 +31,7 @@ import java.util.List;
import java.util.UUID;
import javax.transaction.TransactionalException;
import org.apache.servicecomb.pack.common.EventType;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
import org.apache.servicecomb.pack.omega.context.IdGenerator;
import org.apache.servicecomb.pack.omega.context.OmegaContext;
import org.junit.Before;
@@ -52,6 +53,11 @@ public class SagaStartAnnotationProcessorTest {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return null;
+ }
+
+ @Override
public void close() {
}
diff --git
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/SagaStartAspectTest.java
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/SagaStartAspectTest.java
index 66b55a8..ba4539c 100644
---
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/SagaStartAspectTest.java
+++
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/SagaStartAspectTest.java
@@ -28,6 +28,7 @@ import java.util.List;
import java.util.UUID;
import org.apache.servicecomb.pack.common.EventType;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
import org.apache.servicecomb.pack.omega.context.IdGenerator;
import org.apache.servicecomb.pack.omega.context.OmegaContext;
import org.apache.servicecomb.pack.omega.context.annotations.SagaStart;
@@ -51,6 +52,11 @@ public class SagaStartAspectTest {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return null;
+ }
+
+ @Override
public void close() {
}
diff --git
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/TransactionAspectTest.java
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/TransactionAspectTest.java
index 3c60789..49995ac 100644
---
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/TransactionAspectTest.java
+++
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/TransactionAspectTest.java
@@ -36,6 +36,7 @@ import java.util.List;
import java.util.UUID;
import org.apache.servicecomb.pack.common.EventType;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
import org.apache.servicecomb.pack.omega.context.IdGenerator;
import org.apache.servicecomb.pack.omega.context.OmegaContext;
import org.apache.servicecomb.pack.omega.context.TransactionContextProperties;
@@ -67,6 +68,11 @@ public class TransactionAspectTest {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return null;
+ }
+
+ @Override
public void close() {
}
diff --git
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/tcc/CoordinateMessageHandlerTest.java
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/tcc/CoordinateMessageHandlerTest.java
index 5f72fb0..a7a9628 100644
---
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/tcc/CoordinateMessageHandlerTest.java
+++
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/tcc/CoordinateMessageHandlerTest.java
@@ -25,6 +25,7 @@ import static org.junit.Assert.assertThat;
import java.util.ArrayList;
import java.util.List;
import org.apache.servicecomb.pack.common.TransactionStatus;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
import org.apache.servicecomb.pack.omega.context.CallbackContext;
import org.apache.servicecomb.pack.omega.context.OmegaContext;
import org.apache.servicecomb.pack.omega.transaction.AlphaResponse;
@@ -48,6 +49,11 @@ public class CoordinateMessageHandlerTest {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return null;
+ }
+
+ @Override
public void close() {
}
diff --git
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/tcc/TccParticipatorAspectTest.java
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/tcc/TccParticipatorAspectTest.java
index fc7cb20..24ee4f4 100644
---
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/tcc/TccParticipatorAspectTest.java
+++
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/tcc/TccParticipatorAspectTest.java
@@ -27,6 +27,7 @@ import java.util.ArrayList;
import java.util.List;
import java.util.UUID;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
import org.apache.servicecomb.pack.omega.context.IdGenerator;
import org.apache.servicecomb.pack.omega.context.OmegaContext;
import org.apache.servicecomb.pack.omega.context.TransactionContextProperties;
@@ -68,6 +69,11 @@ public class TccParticipatorAspectTest {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return null;
+ }
+
+ @Override
public void close() {
}
diff --git
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/tcc/TccStartAnnotationProcessorTest.java
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/tcc/TccStartAnnotationProcessorTest.java
index 560f652..e617f7d 100644
---
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/tcc/TccStartAnnotationProcessorTest.java
+++
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/tcc/TccStartAnnotationProcessorTest.java
@@ -29,6 +29,7 @@ import java.util.UUID;
import javax.transaction.TransactionalException;
import org.apache.servicecomb.pack.common.TransactionStatus;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
import org.apache.servicecomb.pack.omega.context.IdGenerator;
import org.apache.servicecomb.pack.omega.context.OmegaContext;
import org.apache.servicecomb.pack.omega.transaction.AlphaResponse;
@@ -62,6 +63,11 @@ public class TccStartAnnotationProcessorTest {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return null;
+ }
+
+ @Override
public void close() {
}
diff --git
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/tcc/TccStartAspectTest.java
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/tcc/TccStartAspectTest.java
index 83f2827..d5b4817 100644
---
a/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/tcc/TccStartAspectTest.java
+++
b/omega/omega-transaction/src/test/java/org/apache/servicecomb/pack/omega/transaction/tcc/TccStartAspectTest.java
@@ -28,6 +28,7 @@ import java.util.List;
import java.util.UUID;
import org.apache.servicecomb.pack.common.TransactionStatus;
+import org.apache.servicecomb.pack.contract.grpc.ServerMeta;
import org.apache.servicecomb.pack.omega.context.IdGenerator;
import org.apache.servicecomb.pack.omega.context.OmegaContext;
import org.apache.servicecomb.pack.omega.context.annotations.TccStart;
@@ -58,6 +59,11 @@ public class TccStartAspectTest {
}
@Override
+ public ServerMeta onGetServerMeta() {
+ return null;
+ }
+
+ @Override
public void close() {
}
diff --git
a/pack-common/src/main/java/org/apache/servicecomb/pack/common/AlphaMetaKeys.java
b/pack-common/src/main/java/org/apache/servicecomb/pack/common/AlphaMetaKeys.java
new file mode 100644
index 0000000..352dd70
--- /dev/null
+++
b/pack-common/src/main/java/org/apache/servicecomb/pack/common/AlphaMetaKeys.java
@@ -0,0 +1,22 @@
+/*
+ * 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.pack.common;
+
+public enum AlphaMetaKeys {
+ AkkaEnabled
+}
\ No newline at end of file
