Bug 1637: Change Rpc actor calls to async

[controller.git] / opendaylight / md-sal / sal-remoterpc-connector / src / main / java / org / opendaylight / controller / remote / rpc / utils / ActorUtil.java

diff --git a/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/utils/ActorUtil.java b/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/utils/ActorUtil.java
index ca14fecb4c4bc65d4d56f66b67b2533fd802ce2a..e2baffa1b13a02e294a8ff2f83361f41b0dd83e9 100644 (file)
--- a/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/utils/ActorUtil.java
+++ b/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/utils/ActorUtil.java
@@ -8,44 +8,15 @@
  */
 package org.opendaylight.controller.remote.rpc.utils;
 
-import akka.actor.ActorRef;
-import akka.util.Timeout;
-import scala.concurrent.Await;
-import scala.concurrent.Future;
 import scala.concurrent.duration.Duration;
 import scala.concurrent.duration.FiniteDuration;
 
 import java.util.concurrent.TimeUnit;
 
-import static akka.pattern.Patterns.ask;
-
 public class ActorUtil {
     public static final FiniteDuration LOCAL_ASK_DURATION = Duration.create(2, TimeUnit.SECONDS);
     public static final FiniteDuration REMOTE_ASK_DURATION = Duration.create(15, TimeUnit.SECONDS);
     public static final FiniteDuration ASK_DURATION = Duration.create(17, TimeUnit.SECONDS);
-    public static final FiniteDuration LOCAL_AWAIT_DURATION = Duration.create(2, TimeUnit.SECONDS);
-    public static final FiniteDuration REMOTE_AWAIT_DURATION = Duration.create(15, TimeUnit.SECONDS);
-    public static final FiniteDuration AWAIT_DURATION = Duration.create(17, TimeUnit.SECONDS);
     public static final FiniteDuration GOSSIP_TICK_INTERVAL = Duration.create(500, TimeUnit.MILLISECONDS);
     public static final String MAILBOX = "bounded-mailbox";
-
-
-    /**
-     * Executes an operation on a local actor and wait for it's response
-     *
-     * @param actor
-     * @param message
-     * @param askDuration
-     * @param awaitDuration
-     * @return The response of the operation
-     */
-    public static Object executeOperation(ActorRef actor, Object message,
-                                          FiniteDuration askDuration, FiniteDuration awaitDuration) throws Exception {
-        Future<Object> future =
-                ask(actor, message, new Timeout(askDuration));
-
-        return Await.result(future, awaitDuration);
-    }
-
-
 }