Prestart haczyk: komunikat dla samego aktora

Question

Powiedzmy zastąpić hak preStart i wysłać wiadomość do self:

Class SomeActor extends Actor { 

    override def preStart(): Unit = { 
    self ! SomeMessage 
    } 

    ... 

} 

mogę się spodziewać, że SomeMessage będzie pierwszą wiadomość w kolejce?

Answer 1

Nie, ponieważ tworzenie aktorów odbywa się asynchronicznie, ktoś mógł zagnieździć wiadomość przed uruchomieniem konstruktora lub preStart. Jeśli potrzebujesz, aby zapewnić przetwarzanie tej wiadomości zanim jakakolwiek inna następnie trzeba użyć become i stash:

self ! SomeMessage 

def receive = initial 

def initial: Receive = { 
    case SomeMessage => 
    // do stuff 
    unstashAll() 
    context become initialized 
    case _ => stash() 
} 

def initialized: Receive = { 
    // your normal behavior 
} 

Musisz mieszać w cechy akka.actor.Stash i skonfigurować tego aktora do używania DequeBasedMailbox .