Say that I have an actor (let's call it the ValveActor) that is taking in
the Twitter stream and needs to split it (or rather copy it) so that the
same stream now flows to 2 different parts of the system. Say for example
that one copy of the stream is going to an actor that stores it somewhere,
Hi Luis,
Receiving and sending 5000 messages per second should not be a problem.
Hopefully the storing and processing of those messages will keep up.
The EventBus is actor system local. It doesn't work over remoting. If you only
have a fixed number of consumers, I would go with a BroadcastGroup
Oh, I didn't realize the EventBus was local to the actor system, must have
missed it in the documentation. Thank you for pointing that out and thank
you for the suggestion. Can't wait for Akka-streams to be released!
--
>> Read the docs: http://akka.io/docs/
>> Check t