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 [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
