Adding Java API for ReceiveTimeout
This commit is contained in:
parent
d68960f0b0
commit
ad6498f3e1
2 changed files with 18 additions and 0 deletions
|
|
@ -69,4 +69,18 @@ public class Actors {
|
|||
public static ActorRef actorOf(final Class<? extends Actor> type) {
|
||||
return Actor$.MODULE$.actorOf(type);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* The message that is sent when an Actor gets a receive timeout.
|
||||
* <pre>
|
||||
* if( message == receiveTimeout() ) {
|
||||
* //Timed out
|
||||
* }
|
||||
* </pre>
|
||||
* @return the single instance of ReceiveTimeout
|
||||
*/
|
||||
public final static ReceiveTimeout$ receiveTimeout() {
|
||||
return ReceiveTimeout$.MODULE$;
|
||||
}
|
||||
}
|
||||
|
|
@ -101,4 +101,8 @@ class ReceiveTimeoutSpec extends JUnitSuite {
|
|||
assert(timeoutLatch.tryAwait(1, TimeUnit.SECONDS) == false)
|
||||
timeoutActor.stop
|
||||
}
|
||||
|
||||
@Test def ActorsReceiveTimeoutShouldBeReceiveTimeout {
|
||||
assert(akka.actor.Actors.receiveTimeout() eq ReceiveTimeout)
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue