akka.testkit
Class JavaTestKit

java.lang.Object
  akka.testkit.JavaTestKit

public class JavaTestKit
extends java.lang.Object

Java API for the TestProbe. Proper JavaDocs to come once JavaDoccing is implemented.

Nested Class Summary

class	JavaTestKit.AwaitCond
class	JavaTestKit.EventFilter<T>
class	JavaTestKit.ExpectMsg<T>
class	JavaTestKit.IgnoreMsg
class	JavaTestKit.ReceiveWhile<T>
class	JavaTestKit.Within

Constructor Summary

JavaTestKit(ActorSystem system)

Method Summary

scala.concurrent.duration.Duration	dilated(scala.concurrent.duration.Duration d)
static scala.concurrent.duration.FiniteDuration	duration(java.lang.String s)
java.lang.Object[]	expectMsgAllOf(scala.concurrent.duration.FiniteDuration max, java.lang.Object... msgs)
java.lang.Object[]	expectMsgAllOf(java.lang.Object... msgs)
<T> T	expectMsgAnyClassOf(java.lang.Class<? extends T>... classes)
java.lang.Object	expectMsgAnyClassOf(scala.concurrent.duration.FiniteDuration max, java.lang.Class<?>... classes)
java.lang.Object	expectMsgAnyOf(scala.concurrent.duration.FiniteDuration max, java.lang.Object... msgs)
java.lang.Object	expectMsgAnyOf(java.lang.Object... msgs)
<T> T	expectMsgClass(java.lang.Class<T> clazz)
<T> T	expectMsgClass(scala.concurrent.duration.FiniteDuration max, java.lang.Class<T> clazz)
<T> T	expectMsgEquals(scala.concurrent.duration.FiniteDuration max, T msg)
<T> T	expectMsgEquals(T msg)
void	expectNoMsg()
void	expectNoMsg(scala.concurrent.duration.FiniteDuration max)
void	forward(ActorRef actor)
ActorRef	getLastSender()
ActorRef	getRef()
scala.concurrent.duration.FiniteDuration	getRemainingTime()
scala.concurrent.duration.FiniteDuration	getRemainingTimeOr(scala.concurrent.duration.FiniteDuration def)
ActorSystem	getSystem()
void	ignoreNoMsg()
boolean	msgAvailable()
void	reply(java.lang.Object msg)
void	send(ActorRef actor, java.lang.Object msg)
void	setAutoPilot(TestActor.AutoPilot pilot)
ActorRef	unwatch(ActorRef ref)
ActorRef	watch(ActorRef ref)

Methods inherited from class java.lang.Object

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

Constructor Detail

JavaTestKit

public JavaTestKit(ActorSystem system)

Method Detail

getRef

public ActorRef getRef()

getSystem

public ActorSystem getSystem()

duration

public static scala.concurrent.duration.FiniteDuration duration(java.lang.String s)

dilated

public scala.concurrent.duration.Duration dilated(scala.concurrent.duration.Duration d)

msgAvailable

public boolean msgAvailable()

getLastSender

public ActorRef getLastSender()

send

public void send(ActorRef actor,
                 java.lang.Object msg)

forward

public void forward(ActorRef actor)

reply

public void reply(java.lang.Object msg)

getRemainingTime

public scala.concurrent.duration.FiniteDuration getRemainingTime()

getRemainingTimeOr

public scala.concurrent.duration.FiniteDuration getRemainingTimeOr(scala.concurrent.duration.FiniteDuration def)

watch

public ActorRef watch(ActorRef ref)

unwatch

public ActorRef unwatch(ActorRef ref)

ignoreNoMsg

public void ignoreNoMsg()

setAutoPilot

public void setAutoPilot(TestActor.AutoPilot pilot)

expectMsgEquals

public <T> T expectMsgEquals(T msg)

expectMsgEquals

public <T> T expectMsgEquals(scala.concurrent.duration.FiniteDuration max,
                             T msg)

expectMsgClass

public <T> T expectMsgClass(java.lang.Class<T> clazz)

expectMsgClass

public <T> T expectMsgClass(scala.concurrent.duration.FiniteDuration max,
                            java.lang.Class<T> clazz)

expectMsgAnyOf

public java.lang.Object expectMsgAnyOf(java.lang.Object... msgs)

expectMsgAnyOf

public java.lang.Object expectMsgAnyOf(scala.concurrent.duration.FiniteDuration max,
                                       java.lang.Object... msgs)

expectMsgAllOf

public java.lang.Object[] expectMsgAllOf(java.lang.Object... msgs)

expectMsgAllOf

public java.lang.Object[] expectMsgAllOf(scala.concurrent.duration.FiniteDuration max,
                                         java.lang.Object... msgs)

expectMsgAnyClassOf

public <T> T expectMsgAnyClassOf(java.lang.Class<? extends T>... classes)

expectMsgAnyClassOf

public java.lang.Object expectMsgAnyClassOf(scala.concurrent.duration.FiniteDuration max,
                                            java.lang.Class<?>... classes)

expectNoMsg

public void expectNoMsg()

expectNoMsg

public void expectNoMsg(scala.concurrent.duration.FiniteDuration max)