Hi Akka team,
I have a question about messages processing by an Actor. In the context of
my Akka application, I defined an Actor with a similar behavior :
case class Worker() extends Actor {
trait Message
case class M1(x : Int) extends Message
case class M2(x : Int) extends Message
trait Result
case Sucess(m : Message) extends Result
case Failed(m : Message) extends Result
def processM1(m : M1) : Future[Result]
def processM2(m : M2) : Future[Result]
override def receive = {
case m : M1 => this.processM1(m) pipeTo sender()
case m : M2 => this.processM2(m) pipeTo sender()
}
}
Imagine that mailbox of a worker *has 4 messages : M1, M2, M3, M4.*
It will process the mailbox messages per message starting by M1, then M2,
then M3 and finally M4.
My question about order processing is : Do an Actor wait the completion of
current message before passing to the next one in the mailbox ?
Based on Akka mechanism, the answer seems to be no. If the actor system
dispatcher has enough threads, it can process M1, M2, M3 and M4 in parallel
but with respecting order of processing. Did I am wrong ?
If I'm a wrong, Does Akka have a mechanism to wait for the completion of
current message processing before passing to the next one ?
In my application, worker actor defined in my question is a member of a
ClusterGroup and I'm pushing messages to it so I was wondering if you have
any advices to reach a such behaviour ?
Alifirat Kilic.
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
