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()); }
