Hi,
I don't know about SEDA in particular, but I think that the Akka Camel Endpoint
will only be one actor in your case. I assume that if you log the actorRef
(getSelf()) you will see only one actor.
An actor only runs on one thread at a time, but seeing different ThreadIds is
normal, since your actor will be scheduled on different threads during
different parts of its life.
B/
On 23 June 2014 at 09:53:02, simafeng...@gmail.com (simafeng...@gmail.com)
wrote:
Hi
I have done a test.
I have a consumer actor receive message from endpoint
"seda:trades?size=1000000&concurrentConsumers=20". But I find from the log,
there are a few different thread ids. Does it means it exists a few
AkkaConsumerActor instances which process message from seda concurrently? code
as below
public class AkkaConsumerActor extends UntypedConsumerActor {
private static final Logger logger = Loggers.getLogger();
public String getEndpointUri() {
return "seda:trades?size=1000000&concurrentConsumers=20";
}
public void onReceive(Object message) {
logger.info("thread id: " + Thread.currentThread().getId());
}
}
On Friday, June 20, 2014 12:02:07 AM UTC+8, Luis Medina wrote:
Hello,
Per the documentation (http://doc.akka.io/docs/akka/2.3.3/java/mailboxes.html)
it appears that the default mailbox of an actor is unbounded in size which I
take it to mean that it will store as many things as it can fit in the memory
of the machine it's running on. If you try giving it more than it can hold, I'm
not sure if you would get some sort of "out of memory" exception or if your
machine would crash. If anything, I'm pretty sure that message would get put in
the deadLetters.
--
>>>>>>>>>> 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 http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
--
Björn Antonsson
Typesafe – Reactive Apps on the JVM
twitter: @bantonsson
--
>>>>>>>>>> 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 http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
