This is an automated email from the ASF dual-hosted git repository.

zhanglei pushed a commit to branch SCB-1321
in repository https://gitbox.apache.org/repos/asf/servicecomb-pack.git

commit 50698eb2931938b338515c33604787319c9af50d
Author: Lei Zhang <[email protected]>
AuthorDate: Wed Jul 10 18:44:56 2019 +0800

    SCB-1321 Delete unused methods
---
 .../pack/alpha/fsm/event/consumer/SagaEventConsumer.java      | 11 +----------
 1 file changed, 1 insertion(+), 10 deletions(-)

diff --git 
a/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/event/consumer/SagaEventConsumer.java
 
b/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/event/consumer/SagaEventConsumer.java
index 709cc40..758880b 100644
--- 
a/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/event/consumer/SagaEventConsumer.java
+++ 
b/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/event/consumer/SagaEventConsumer.java
@@ -17,30 +17,21 @@
 
 package org.apache.servicecomb.pack.alpha.fsm.event.consumer;
 
-import akka.actor.ActorNotFound;
 import akka.actor.ActorRef;
-import akka.actor.ActorSelection;
 import akka.actor.ActorSystem;
-import akka.util.Timeout;
-import com.google.common.base.Optional;
 import com.google.common.eventbus.Subscribe;
 import java.lang.invoke.MethodHandles;
 import java.util.HashMap;
 import java.util.Map;
-import java.util.concurrent.TimeUnit;
 import org.apache.servicecomb.pack.alpha.fsm.SagaActor;
 import org.apache.servicecomb.pack.alpha.fsm.event.base.BaseEvent;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
-import scala.concurrent.Await;
-import scala.concurrent.Future;
 
 public class SagaEventConsumer {
   private static final Logger LOG = 
LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
 
-  public static final Timeout TIMEOUT = new Timeout(5, TimeUnit.SECONDS);
-
   @Autowired
   ActorSystem system;
 
@@ -50,7 +41,7 @@ public class SagaEventConsumer {
    * Receive fsm message
    * */
   @Subscribe
-  public void receiveSagaEvent(BaseEvent event) throws Exception {
+  public void receiveSagaEvent(BaseEvent event) {
     if(LOG.isDebugEnabled()){
       LOG.debug("receive {} ", event.toString());
     }

Reply via email to