Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Multiple workers actors #50

Open
eugenemiretsky opened this issue May 3, 2016 · 1 comment
Open

Multiple workers actors #50

eugenemiretsky opened this issue May 3, 2016 · 1 comment

Comments

@eugenemiretsky
Copy link

There are many stream consumer actors created (FSMStreams), but only one worker actor - this essentially turns any non-trivial worker into a bottle neck - would it make sense to have a consumer actor per stream?

@sclasen
Copy link
Owner

sclasen commented May 3, 2016

You only need provide an ActorRef to any of the Consumers in this library. They can be backed by a standard actor or any of the existing akka routers or other pooling mechanism.

In addition the actor ref provided to this library doesnt necessarily need to be the actor that is sending the StreamFSM.Processed acknowledgements back to the consumer, any actor that gets forwarded a message from the consumer can respond to it. (Assuming sender is properly maintained across forwarding)

Is there another requirement you have that is not met here?

Cheers!

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants