SCB-1627 Rename CompensateAskFailedException to CompensateAckFailedException
diff --git a/alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/CompositeOmegaCallback.java b/alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/CompositeOmegaCallback.java
index 95b0df6..23b585a 100644
--- a/alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/CompositeOmegaCallback.java
+++ b/alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/CompositeOmegaCallback.java
@@ -24,7 +24,7 @@
import java.util.Iterator;
import java.util.Map;
-import org.apache.servicecomb.pack.alpha.core.exception.CompensateAskFailedException;
+import org.apache.servicecomb.pack.alpha.core.exception.CompensateAckFailedException;
import org.apache.servicecomb.pack.alpha.core.exception.CompensateConnectException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -59,7 +59,7 @@
} catch (CompensateConnectException e) {
serviceCallbacks.values().remove(omegaCallback);
throw e;
- } catch (CompensateAskFailedException e) {
+ } catch (CompensateAckFailedException e) {
throw e;
} catch (Exception e) {
serviceCallbacks.values().remove(omegaCallback);
diff --git a/alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/exception/CompensateAskFailedException.java b/alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/exception/CompensateAckFailedException.java
similarity index 88%
rename from alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/exception/CompensateAskFailedException.java
rename to alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/exception/CompensateAckFailedException.java
index 4adbe2b..b6dc51e 100644
--- a/alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/exception/CompensateAskFailedException.java
+++ b/alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/exception/CompensateAckFailedException.java
@@ -17,8 +17,8 @@
package org.apache.servicecomb.pack.alpha.core.exception;
-public class CompensateAskFailedException extends RuntimeException {
- public CompensateAskFailedException(String cause) {
+public class CompensateAckFailedException extends RuntimeException {
+ public CompensateAckFailedException(String cause) {
super(cause);
}
}
\ No newline at end of file
diff --git a/alpha/alpha-server/src/main/java/org/apache/servicecomb/pack/alpha/server/fsm/GrpcOmegaCallback.java b/alpha/alpha-server/src/main/java/org/apache/servicecomb/pack/alpha/server/fsm/GrpcOmegaCallback.java
index 3187892..1624479 100644
--- a/alpha/alpha-server/src/main/java/org/apache/servicecomb/pack/alpha/server/fsm/GrpcOmegaCallback.java
+++ b/alpha/alpha-server/src/main/java/org/apache/servicecomb/pack/alpha/server/fsm/GrpcOmegaCallback.java
@@ -22,7 +22,7 @@
import java.lang.invoke.MethodHandles;
import org.apache.servicecomb.pack.alpha.core.OmegaCallback;
import org.apache.servicecomb.pack.alpha.core.TxEvent;
-import org.apache.servicecomb.pack.alpha.core.exception.CompensateAskFailedException;
+import org.apache.servicecomb.pack.alpha.core.exception.CompensateAckFailedException;
import org.apache.servicecomb.pack.alpha.core.exception.CompensateConnectException;
import org.apache.servicecomb.pack.alpha.core.fsm.CompensateAskType;
import org.apache.servicecomb.pack.contract.grpc.GrpcCompensateCommand;
@@ -57,7 +57,7 @@
}else{
LOG.info("compensate ask "+compensateAskWait.getType().name());
if(compensateAskWait.getType() == CompensateAskType.Failed){
- throw new CompensateAskFailedException("An exception is thrown inside the compensation method");
+ throw new CompensateAckFailedException("An exception is thrown inside the compensation method");
}
}
} catch (InterruptedException e) {
