public class TestProbe extends TestKit
Constructor and Description |
---|
TestProbe(ActorSystem _application) |
TestProbe(ActorSystem _application,
java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
protected static void |
akka$testkit$TestKitBase$_setter_$akka$testkit$TestKitBase$$queue_$eq(java.util.concurrent.LinkedBlockingDeque<TestActor.Message> x$1) |
protected static void |
akka$testkit$TestKitBase$_setter_$testActor_$eq(ActorRef x$1) |
protected static void |
akka$testkit$TestKitBase$_setter_$testKitSettings_$eq(TestKitSettings x$1) |
static void |
akka$testkit$TestKitBase$$end_$eq(scala.concurrent.duration.Duration x$1) |
static scala.concurrent.duration.Duration |
akka$testkit$TestKitBase$$end() |
static void |
akka$testkit$TestKitBase$$lastWasNoMsg_$eq(boolean x$1) |
static boolean |
akka$testkit$TestKitBase$$lastWasNoMsg() |
static java.util.concurrent.LinkedBlockingDeque<TestActor.Message> |
akka$testkit$TestKitBase$$queue() |
static TestProbe |
apply(ActorSystem system) |
static TestProbe |
apply(java.lang.String name,
ActorSystem system) |
static void |
awaitAssert(scala.Function0<java.lang.Object> a,
scala.concurrent.duration.Duration max,
scala.concurrent.duration.Duration interval) |
static scala.concurrent.duration.Duration |
awaitAssert$default$2() |
static scala.concurrent.duration.Duration |
awaitAssert$default$3() |
static void |
awaitCond(scala.Function0<java.lang.Object> p,
scala.concurrent.duration.Duration max,
scala.concurrent.duration.Duration interval,
java.lang.String message) |
static scala.concurrent.duration.Duration |
awaitCond$default$2() |
static scala.concurrent.duration.Duration |
awaitCond$default$3() |
static java.lang.String |
awaitCond$default$4() |
static ActorRef |
childActorOf(Props props) |
static ActorRef |
childActorOf(Props props,
java.lang.String name) |
static ActorRef |
childActorOf(Props props,
java.lang.String name,
SupervisorStrategy supervisorStrategy) |
static ActorRef |
childActorOf(Props props,
SupervisorStrategy supervisorStrategy) |
static <T> T |
expectMsg(scala.concurrent.duration.FiniteDuration max,
java.lang.String hint,
T obj) |
static <T> T |
expectMsg(scala.concurrent.duration.FiniteDuration max,
T obj) |
static <T> T |
expectMsg(T obj) |
static <T> scala.collection.immutable.Seq<T> |
expectMsgAllClassOf(scala.concurrent.duration.FiniteDuration max,
scala.collection.Seq<java.lang.Class<? extends T>> obj) |
static <T> scala.collection.immutable.Seq<T> |
expectMsgAllClassOf(scala.collection.Seq<java.lang.Class<? extends T>> obj) |
static <T> scala.collection.immutable.Seq<T> |
expectMsgAllConformingOf(scala.concurrent.duration.FiniteDuration max,
scala.collection.Seq<java.lang.Class<? extends T>> obj) |
static <T> scala.collection.immutable.Seq<T> |
expectMsgAllConformingOf(scala.collection.Seq<java.lang.Class<? extends T>> obj) |
static <T> scala.collection.immutable.Seq<T> |
expectMsgAllOf(scala.concurrent.duration.FiniteDuration max,
scala.collection.Seq<T> obj) |
static <T> scala.collection.immutable.Seq<T> |
expectMsgAllOf(scala.collection.Seq<T> obj) |
static <C> C |
expectMsgAnyClassOf(scala.concurrent.duration.FiniteDuration max,
scala.collection.Seq<java.lang.Class<? extends C>> obj) |
static <C> C |
expectMsgAnyClassOf(scala.collection.Seq<java.lang.Class<? extends C>> obj) |
static <T> T |
expectMsgAnyOf(scala.concurrent.duration.FiniteDuration max,
scala.collection.Seq<T> obj) |
static <T> T |
expectMsgAnyOf(scala.collection.Seq<T> obj) |
static <C> C |
expectMsgClass(java.lang.Class<C> c) |
static <C> C |
expectMsgClass(scala.concurrent.duration.FiniteDuration max,
java.lang.Class<C> c) |
static <T> T |
expectMsgPF(scala.concurrent.duration.Duration max,
java.lang.String hint,
scala.PartialFunction<java.lang.Object,T> f) |
static <T> scala.concurrent.duration.Duration |
expectMsgPF$default$1() |
static <T> java.lang.String |
expectMsgPF$default$2() |
static <T> T |
expectMsgType(scala.reflect.ClassTag<T> t) |
static <T> T |
expectMsgType(scala.concurrent.duration.FiniteDuration max,
scala.reflect.ClassTag<T> t) |
static void |
expectNoMsg() |
static void |
expectNoMsg(scala.concurrent.duration.FiniteDuration max) |
static Terminated |
expectTerminated(ActorRef target,
scala.concurrent.duration.Duration max) |
static scala.concurrent.duration.Duration |
expectTerminated$default$2() |
static java.lang.Object |
fishForMessage(scala.concurrent.duration.Duration max,
java.lang.String hint,
scala.PartialFunction<java.lang.Object,java.lang.Object> f) |
static scala.concurrent.duration.Duration |
fishForMessage$default$1() |
static java.lang.String |
fishForMessage$default$2() |
void |
forward(ActorRef actor,
java.lang.Object msg)
Forward this message as if in the TestActor's receive method with self.forward.
|
static void |
ignoreMsg(scala.PartialFunction<java.lang.Object,java.lang.Object> f) |
static void |
ignoreNoMsg() |
static void |
lastMessage_$eq(TestActor.Message x$1) |
static TestActor.Message |
lastMessage() |
static ActorRef |
lastSender() |
static boolean |
msgAvailable() |
static scala.concurrent.duration.FiniteDuration |
now() |
static scala.collection.immutable.Seq<java.lang.Object> |
receiveN(int n) |
static scala.collection.immutable.Seq<java.lang.Object> |
receiveN(int n,
scala.concurrent.duration.FiniteDuration max) |
static java.lang.Object |
receiveOne(scala.concurrent.duration.Duration max) |
static <T> scala.collection.immutable.Seq<T> |
receiveWhile(scala.concurrent.duration.Duration max,
scala.concurrent.duration.Duration idle,
int messages,
scala.PartialFunction<java.lang.Object,T> f) |
static <T> scala.concurrent.duration.Duration |
receiveWhile$default$1() |
static <T> scala.concurrent.duration.Duration |
receiveWhile$default$2() |
static <T> int |
receiveWhile$default$3() |
ActorRef |
ref()
Shorthand to get the testActor.
|
static scala.concurrent.duration.FiniteDuration |
remaining() |
static scala.concurrent.duration.FiniteDuration |
remainingOr(scala.concurrent.duration.FiniteDuration duration) |
static scala.concurrent.duration.FiniteDuration |
remainingOrDefault() |
void |
reply(java.lang.Object msg)
Send message to the sender of the last dequeued message.
|
void |
send(ActorRef actor,
java.lang.Object msg)
Send message to an actor while using the probe's TestActor as the sender.
|
ActorRef |
sender()
Get sender of last received message.
|
static void |
setAutoPilot(TestActor.AutoPilot pilot) |
static void |
shutdown(ActorSystem actorSystem,
scala.concurrent.duration.Duration duration,
boolean verifySystemShutdown) |
static ActorSystem |
shutdown$default$1() |
static scala.concurrent.duration.Duration |
shutdown$default$2() |
static boolean |
shutdown$default$3() |
static ActorSystem |
system() |
static ActorRef |
testActor() |
protected java.lang.String |
testActorName()
Defines the testActor name.
|
static TestKitSettings |
testKitSettings() |
static ActorRef |
unwatch(ActorRef ref) |
static ActorRef |
watch(ActorRef ref) |
static <T> T |
within(scala.concurrent.duration.FiniteDuration min,
scala.concurrent.duration.FiniteDuration max,
scala.Function0<T> f) |
static <T> T |
within(scala.concurrent.duration.FiniteDuration max,
scala.Function0<T> f) |
awaitCond, lastMessage, shutdownActorSystem, system, testActor, testActorId, testKitSettings
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
awaitAssert, awaitCond, checkMissingAndUnexpected, childActorOf, childActorOf, childActorOf, childActorOf, expectMsg_internal, expectMsg, expectMsg, expectMsg, expectMsgAllClassOf, expectMsgAllClassOf, expectMsgAllConformingOf, expectMsgAllConformingOf, expectMsgAllOf_internal, expectMsgAllOf, expectMsgAllOf, expectMsgAnyClassOf_internal, expectMsgAnyClassOf, expectMsgAnyClassOf, expectMsgAnyOf_internal, expectMsgAnyOf, expectMsgAnyOf, expectMsgClass_internal, expectMsgClass, expectMsgClass, expectMsgPF, expectMsgType, expectMsgType, expectNoMsg_internal, expectNoMsg, expectNoMsg, expectTerminated, fishForMessage, format, ignoreMsg, ignoreNoMsg, internalExpectMsgAllClassOf, internalExpectMsgAllConformingOf, lastSender, msgAvailable, now, receiveN_internal, receiveN, receiveN, receiveOne, receiveWhile, remaining, remainingOr, remainingOrDefault, remainingOrDilated, setAutoPilot, shutdown, unwatch, watch, within, within
public TestProbe(ActorSystem _application, java.lang.String name)
public TestProbe(ActorSystem _application)
public static TestProbe apply(ActorSystem system)
public static TestProbe apply(java.lang.String name, ActorSystem system)
public static ActorRef lastSender()
public static void ignoreMsg(scala.PartialFunction<java.lang.Object,java.lang.Object> f)
public static void ignoreNoMsg()
public static void setAutoPilot(TestActor.AutoPilot pilot)
public static scala.concurrent.duration.FiniteDuration now()
public static scala.concurrent.duration.FiniteDuration remainingOrDefault()
public static scala.concurrent.duration.FiniteDuration remaining()
public static scala.concurrent.duration.FiniteDuration remainingOr(scala.concurrent.duration.FiniteDuration duration)
public static boolean msgAvailable()
public static void awaitCond(scala.Function0<java.lang.Object> p, scala.concurrent.duration.Duration max, scala.concurrent.duration.Duration interval, java.lang.String message)
public static void awaitAssert(scala.Function0<java.lang.Object> a, scala.concurrent.duration.Duration max, scala.concurrent.duration.Duration interval)
public static <T> T within(scala.concurrent.duration.FiniteDuration min, scala.concurrent.duration.FiniteDuration max, scala.Function0<T> f)
public static <T> T within(scala.concurrent.duration.FiniteDuration max, scala.Function0<T> f)
public static <T> T expectMsg(T obj)
public static <T> T expectMsg(scala.concurrent.duration.FiniteDuration max, T obj)
public static <T> T expectMsg(scala.concurrent.duration.FiniteDuration max, java.lang.String hint, T obj)
public static <T> T expectMsgPF(scala.concurrent.duration.Duration max, java.lang.String hint, scala.PartialFunction<java.lang.Object,T> f)
public static Terminated expectTerminated(ActorRef target, scala.concurrent.duration.Duration max)
public static java.lang.Object fishForMessage(scala.concurrent.duration.Duration max, java.lang.String hint, scala.PartialFunction<java.lang.Object,java.lang.Object> f)
public static <T> T expectMsgType(scala.reflect.ClassTag<T> t)
public static <T> T expectMsgType(scala.concurrent.duration.FiniteDuration max, scala.reflect.ClassTag<T> t)
public static <C> C expectMsgClass(java.lang.Class<C> c)
public static <C> C expectMsgClass(scala.concurrent.duration.FiniteDuration max, java.lang.Class<C> c)
public static <T> T expectMsgAnyOf(scala.collection.Seq<T> obj)
public static <T> T expectMsgAnyOf(scala.concurrent.duration.FiniteDuration max, scala.collection.Seq<T> obj)
public static <C> C expectMsgAnyClassOf(scala.collection.Seq<java.lang.Class<? extends C>> obj)
public static <C> C expectMsgAnyClassOf(scala.concurrent.duration.FiniteDuration max, scala.collection.Seq<java.lang.Class<? extends C>> obj)
public static <T> scala.collection.immutable.Seq<T> expectMsgAllOf(scala.collection.Seq<T> obj)
public static <T> scala.collection.immutable.Seq<T> expectMsgAllOf(scala.concurrent.duration.FiniteDuration max, scala.collection.Seq<T> obj)
public static <T> scala.collection.immutable.Seq<T> expectMsgAllClassOf(scala.collection.Seq<java.lang.Class<? extends T>> obj)
public static <T> scala.collection.immutable.Seq<T> expectMsgAllClassOf(scala.concurrent.duration.FiniteDuration max, scala.collection.Seq<java.lang.Class<? extends T>> obj)
public static <T> scala.collection.immutable.Seq<T> expectMsgAllConformingOf(scala.collection.Seq<java.lang.Class<? extends T>> obj)
public static <T> scala.collection.immutable.Seq<T> expectMsgAllConformingOf(scala.concurrent.duration.FiniteDuration max, scala.collection.Seq<java.lang.Class<? extends T>> obj)
public static void expectNoMsg()
public static void expectNoMsg(scala.concurrent.duration.FiniteDuration max)
public static <T> scala.collection.immutable.Seq<T> receiveWhile(scala.concurrent.duration.Duration max, scala.concurrent.duration.Duration idle, int messages, scala.PartialFunction<java.lang.Object,T> f)
public static scala.collection.immutable.Seq<java.lang.Object> receiveN(int n)
public static scala.collection.immutable.Seq<java.lang.Object> receiveN(int n, scala.concurrent.duration.FiniteDuration max)
public static java.lang.Object receiveOne(scala.concurrent.duration.Duration max)
public static void shutdown(ActorSystem actorSystem, scala.concurrent.duration.Duration duration, boolean verifySystemShutdown)
public static ActorRef childActorOf(Props props, java.lang.String name, SupervisorStrategy supervisorStrategy)
public static ActorRef childActorOf(Props props, SupervisorStrategy supervisorStrategy)
public static scala.concurrent.duration.Duration awaitCond$default$2()
public static scala.concurrent.duration.Duration awaitCond$default$3()
public static java.lang.String awaitCond$default$4()
public static scala.concurrent.duration.Duration awaitAssert$default$2()
public static scala.concurrent.duration.Duration awaitAssert$default$3()
public static <T> scala.concurrent.duration.Duration expectMsgPF$default$1()
public static <T> java.lang.String expectMsgPF$default$2()
public static scala.concurrent.duration.Duration expectTerminated$default$2()
public static scala.concurrent.duration.Duration fishForMessage$default$1()
public static java.lang.String fishForMessage$default$2()
public static <T> scala.concurrent.duration.Duration receiveWhile$default$1()
public static <T> scala.concurrent.duration.Duration receiveWhile$default$2()
public static <T> int receiveWhile$default$3()
public static ActorSystem shutdown$default$1()
public static scala.concurrent.duration.Duration shutdown$default$2()
public static boolean shutdown$default$3()
public static ActorSystem system()
public static TestKitSettings testKitSettings()
public static java.util.concurrent.LinkedBlockingDeque<TestActor.Message> akka$testkit$TestKitBase$$queue()
public static TestActor.Message lastMessage()
public static void lastMessage_$eq(TestActor.Message x$1)
public static ActorRef testActor()
public static scala.concurrent.duration.Duration akka$testkit$TestKitBase$$end()
public static void akka$testkit$TestKitBase$$end_$eq(scala.concurrent.duration.Duration x$1)
public static boolean akka$testkit$TestKitBase$$lastWasNoMsg()
public static void akka$testkit$TestKitBase$$lastWasNoMsg_$eq(boolean x$1)
protected static void akka$testkit$TestKitBase$_setter_$testKitSettings_$eq(TestKitSettings x$1)
protected static final void akka$testkit$TestKitBase$_setter_$akka$testkit$TestKitBase$$queue_$eq(java.util.concurrent.LinkedBlockingDeque<TestActor.Message> x$1)
protected static void akka$testkit$TestKitBase$_setter_$testActor_$eq(ActorRef x$1)
public ActorRef ref()
protected java.lang.String testActorName()
TestKitBase
testActorName
in interface TestKitBase
testActorName
in class TestKit
public void send(ActorRef actor, java.lang.Object msg)
actor
- (undocumented)msg
- (undocumented)public void forward(ActorRef actor, java.lang.Object msg)
actor
- (undocumented)msg
- (undocumented)public ActorRef sender()
public void reply(java.lang.Object msg)
msg
- (undocumented)