public class TestProbe extends TestKit
Constructor and Description |
---|
TestProbe(akka.actor.ActorSystem _application) |
TestProbe(akka.actor.ActorSystem _application,
java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
static TestProbe |
apply(akka.actor.ActorSystem system) |
static TestProbe |
apply(java.lang.String name,
akka.actor.ActorSystem system) |
void |
forward(akka.actor.ActorRef actor,
java.lang.Object msg)
Forward this message as if in the TestActor's receive method with self.forward.
|
akka.actor.ActorRef |
ref()
Shorthand to get the testActor.
|
void |
reply(java.lang.Object msg)
Send message to the sender of the last dequeued message.
|
void |
send(akka.actor.ActorRef actor,
java.lang.Object msg)
Send message to an actor while using the probe's TestActor as the sender.
|
akka.actor.ActorRef |
sender()
Get sender of last received message.
|
protected java.lang.String |
testActorName()
Defines the testActor name.
|
awaitCond, now, shutdownActorSystem, system, testActorId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
awaitAssert, awaitCond, checkMissingAndUnexpected, end, 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, lastMessage, lastSender, lastWasNoMsg, msgAvailable, now, queue, receiveN_internal, receiveN, receiveN, receiveOne, receiveWhile, remaining, remainingOr, remainingOrDefault, remainingOrDilated, setAutoPilot, shutdown, testActor, testKitSettings, unwatch, watch, within, within
public TestProbe(akka.actor.ActorSystem _application, java.lang.String name)
public TestProbe(akka.actor.ActorSystem _application)
public static TestProbe apply(akka.actor.ActorSystem system)
public static TestProbe apply(java.lang.String name, akka.actor.ActorSystem system)
public akka.actor.ActorRef ref()
protected java.lang.String testActorName()
TestKitBase
public void send(akka.actor.ActorRef actor, java.lang.Object msg)
actor
- (undocumented)msg
- (undocumented)public void forward(akka.actor.ActorRef actor, java.lang.Object msg)
actor
- (undocumented)msg
- (undocumented)public akka.actor.ActorRef sender()
public void reply(java.lang.Object msg)
msg
- (undocumented)