akka.actor.dsl
Class Inbox.InboxActor
java.lang.Object
akka.actor.dsl.Inbox.InboxActor
- All Implemented Interfaces:
- Actor, ActorLogging
- Enclosing interface:
- Inbox
public private static class Inbox.InboxActor
- extends java.lang.Object
- implements Actor, ActorLogging
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Inbox.InboxActor
public Inbox.InboxActor(int size)
clients
public scala.collection.mutable.Queue<Inbox.Query> clients()
messages
public scala.collection.mutable.Queue<java.lang.Object> messages()
clientsByTimeout
public scala.collection.immutable.TreeSet<Inbox.Query> clientsByTimeout()
printedWarning
public boolean printedWarning()
enqueueQuery
public void enqueueQuery(Inbox.Query q)
enqueueMessage
public void enqueueMessage(java.lang.Object msg)
currentMsg
public java.lang.Object currentMsg()
clientPredicate
public scala.Function1<Inbox.Query,java.lang.Object> clientPredicate()
currentSelect
public Inbox.Select currentSelect()
messagePredicate
public scala.Function1<java.lang.Object,java.lang.Object> messagePredicate()
currentDeadline
public scala.Option<scala.Tuple2<scala.concurrent.duration.Deadline,Cancellable>> currentDeadline()
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
- Description copied from interface:
Actor
- This defines the initial actor behavior, it must return a partial function
with the actor logic.
- Specified by:
receive
in interface Actor