org.opendaylight.controller.cluster.common.actor

Class ExplicitAsk

java.lang.Object

org.opendaylight.controller.cluster.common.actor.ExplicitAsk

@Beta
public final class ExplicitAsk
extends Object

Unfortunately Akka's explicit ask pattern does not work with its Java API, as it fails to invoke passed message. In order to make this work for now, we tap directly into ExplicitAskSupport and use a Scala function instead of akka.japi.Function.

Author:

Robert Varga

Method Summary

Modifier and Type	Method and Description
static scala.concurrent.Future<Object>	ask(akka.actor.ActorRef actor, Function<akka.actor.ActorRef,?> function, akka.util.Timeout timeout)
static scala.concurrent.Future<Object>	ask(akka.actor.ActorRef actor, scala.Function1<akka.actor.ActorRef,?> function, akka.util.Timeout timeout)
static scala.concurrent.Future<Object>	ask(akka.actor.ActorSelection actor, Function<akka.actor.ActorRef,?> function, akka.util.Timeout timeout)
static scala.concurrent.Future<Object>	ask(akka.actor.ActorSelection actor, scala.Function1<akka.actor.ActorRef,?> function, akka.util.Timeout timeout)
static <T> scala.Function1<akka.actor.ActorRef,T>	toScala(Function<akka.actor.ActorRef,T> function)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

toScala

public static <T> scala.Function1<akka.actor.ActorRef,T> toScala(Function<akka.actor.ActorRef,T> function)

ask

public static scala.concurrent.Future<Object> ask(akka.actor.ActorRef actor,
                                                  scala.Function1<akka.actor.ActorRef,?> function,
                                                  akka.util.Timeout timeout)

ask

public static scala.concurrent.Future<Object> ask(akka.actor.ActorSelection actor,
                                                  scala.Function1<akka.actor.ActorRef,?> function,
                                                  akka.util.Timeout timeout)

ask

public static scala.concurrent.Future<Object> ask(akka.actor.ActorRef actor,
                                                  Function<akka.actor.ActorRef,?> function,
                                                  akka.util.Timeout timeout)

ask

public static scala.concurrent.Future<Object> ask(akka.actor.ActorSelection actor,
                                                  Function<akka.actor.ActorRef,?> function,
                                                  akka.util.Timeout timeout)