akka.testkit

Class JavaTestKit.ReceiveWhile<T>

java.lang.Object

akka.testkit.JavaTestKit.ReceiveWhile<T>

Enclosing class:

JavaTestKit

public abstract class JavaTestKit.ReceiveWhile<T>
extends java.lang.Object

Receive a series of messages until one does not match the given match function or the idle timeout is met (disabled by default) or the overall maximum duration is elapsed. Returns the sequence of messages.

Note that it is not an error to hit the max duration in this case.

One possible use of this method is for testing whether messages of certain characteristics are generated at a certain rate.

Constructor Summary

Constructors

Constructor and Description
ReceiveWhile(java.lang.Class<T> clazz)
ReceiveWhile(java.lang.Class<T> clazz, scala.concurrent.duration.Duration max)
ReceiveWhile(java.lang.Class<T> clazz, scala.concurrent.duration.Duration max, scala.concurrent.duration.Duration idle, int messages)
ReceiveWhile(java.lang.Class<T> clazz, scala.concurrent.duration.Duration max, int messages)

Method Summary

Modifier and Type	Method and Description
T[]	get()
protected abstract T	match(java.lang.Object msg)
protected java.lang.RuntimeException	noMatch()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReceiveWhile

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

ReceiveWhile

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

ReceiveWhile

public ReceiveWhile(java.lang.Class<T> clazz,
                    scala.concurrent.duration.Duration max,
                    int messages)

ReceiveWhile

public ReceiveWhile(java.lang.Class<T> clazz,
                    scala.concurrent.duration.Duration max,
                    scala.concurrent.duration.Duration idle,
                    int messages)

Method Detail

match

protected abstract T match(java.lang.Object msg)
                    throws java.lang.Exception

Throws:

java.lang.Exception

noMatch

protected java.lang.RuntimeException noMatch()

get

public T[] get()