@rogeralsing That is basically it. In your example you work with a batch of messages. So in this case if a message fails for on a specific actor I no longer want any messages to process for that given actor. The reason is I want to preserve the order of the messages from the queue based on the hash. I guess I could use a Circuit Breaker just for that specific route and once it gets tripped it would stash the messages along with a supervisor that would not retry if the circuit is tripped. This will probably never be an issue but theoretically a service like a DB could be there one second then gone the next and by the time it returns the message could conceivably timeout.
A quick question on async/await stuff. Are there currently any plans to implement async message handlers in other actor types, e.g. TypedActor, UntypedActor and in the F# API?
You have a kind of prostetic for that in
ReceiveActor, but in general this is not plan in Akka 1.x. It would require serious changes in akka internals to be fully integrated
@Horusiath just to get some updates... was this discussed internally for akka 2 or some future roadmap? I remember you talking about the possibility of akka typed returning promises
we don't have scheduled akka-typed yet ;) I'm fine with supporting async/await from there, but still
it's not a plan to be realizable in this year IMO
ok. thanks!
I think that finishing cluster-associated plugins and reactive streams implementation this year would be great success... there is realy a lot of work to do
I'm starting to look at cluster now
lots of things to learn, not much time
@Horusiath cheers, just writing the chapter on implementing actors, wanted to make sure there wasn't going to be any major changes to it soon
as always
@Aaronontheweb do we have docs for multinode test kit somewhere? I don't know if I can start using it and how does it differs from JVM implementation
@Horusiath nope, going to have to read the source code in the meantime
I'm currently working on both
Akka.Cluster.Sharding and pub-sub/client parts of the Akka.Cluster.Tools and I will probably need to be sure if this is working soon in order to complete specs