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 2018/12/10 01:33:07 UTC
[servicecomb-pack] 02/02: SCB-817 Fixed the event type name issues
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 654f24f71b52403d1449e06837dd9c8490f30775
Author: Willem Jiang <ji...@huawei.com>
AuthorDate: Mon Dec 10 09:32:44 2018 +0800
SCB-817 Fixed the event type name issues
---
.../saga/omega/transaction/spring/MessageConfig.java | 14 ++++++--------
.../saga/omega/transaction/tcc/TccEventService.java | 6 +++---
2 files changed, 9 insertions(+), 11 deletions(-)
diff --git a/omega/omega-spring-tx/src/test/java/org/apache/servicecomb/saga/omega/transaction/spring/MessageConfig.java b/omega/omega-spring-tx/src/test/java/org/apache/servicecomb/saga/omega/transaction/spring/MessageConfig.java
index d99bc1b..7b650ef 100644
--- a/omega/omega-spring-tx/src/test/java/org/apache/servicecomb/saga/omega/transaction/spring/MessageConfig.java
+++ b/omega/omega-spring-tx/src/test/java/org/apache/servicecomb/saga/omega/transaction/spring/MessageConfig.java
@@ -23,12 +23,10 @@ import org.apache.servicecomb.saga.omega.context.CallbackContext;
import org.apache.servicecomb.saga.omega.context.IdGenerator;
import org.apache.servicecomb.saga.omega.context.OmegaContext;
import org.apache.servicecomb.saga.omega.transaction.AlphaResponse;
-import org.apache.servicecomb.saga.omega.transaction.MessageSender;
import org.apache.servicecomb.saga.omega.transaction.SagaMessageSender;
import org.apache.servicecomb.saga.omega.transaction.TxEvent;
import org.apache.servicecomb.saga.omega.transaction.tcc.DefaultParametersContext;
import org.apache.servicecomb.saga.omega.transaction.tcc.ParametersContext;
-import org.apache.servicecomb.saga.omega.transaction.tcc.TccEventService;
import org.apache.servicecomb.saga.omega.transaction.tcc.TccMessageSender;
import org.apache.servicecomb.saga.omega.transaction.tcc.events.CoordinatedEvent;
import org.apache.servicecomb.saga.omega.transaction.tcc.events.ParticipatedEvent;
@@ -125,20 +123,20 @@ public class MessageConfig {
}
@Override
- public AlphaResponse participate(ParticipatedEvent participateEvent) {
- messages.add(participateEvent.toString());
+ public AlphaResponse participate(ParticipatedEvent participatedEvent) {
+ messages.add(participatedEvent.toString());
return new AlphaResponse(false);
}
@Override
- public AlphaResponse tccTransactionStart(TccStartedEvent tccStartEvent) {
- messages.add(tccStartEvent.toString());
+ public AlphaResponse tccTransactionStart(TccStartedEvent tccStartedEvent) {
+ messages.add(tccStartedEvent.toString());
return new AlphaResponse(false);
}
@Override
- public AlphaResponse tccTransactionStop(TccEndedEvent tccEndEvent) {
- messages.add(tccEndEvent.toString());
+ public AlphaResponse tccTransactionStop(TccEndedEvent tccEndedEvent) {
+ messages.add(tccEndedEvent.toString());
return new AlphaResponse(false);
}
diff --git a/omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/tcc/TccEventService.java b/omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/tcc/TccEventService.java
index f5bdcfd..6c5b7e2 100644
--- a/omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/tcc/TccEventService.java
+++ b/omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/tcc/TccEventService.java
@@ -33,11 +33,11 @@ public interface TccEventService {
String target();
- AlphaResponse participate(ParticipatedEvent participateEvent);
+ AlphaResponse participate(ParticipatedEvent participatedEvent);
- AlphaResponse tccTransactionStart(TccStartedEvent tccStartEvent);
+ AlphaResponse tccTransactionStart(TccStartedEvent tccStartedEvent);
- AlphaResponse tccTransactionStop(TccEndedEvent tccEndEvent);
+ AlphaResponse tccTransactionStop(TccEndedEvent tccEndedEvent);
AlphaResponse coordinate(CoordinatedEvent coordinatedEvent);