Ok, so I am using it correctly :)
The NACK-ing mailbox is something I will take a look at. But I'd rather
spin it with "Hey, slow down I am 90% full" to retain some buffering and
maybe get rid of messages already in flight.
But I was basically just curious because in theory I should not run into
such a scenario using Reactive Streams.
Thanks,
Jochen
Am Montag, 28. Dezember 2015 17:57:44 UTC+1 schrieb Konrad Malawski:
>
> Hi Jochen,
> The bounded mailboxes are designed around the idea that in Akka delivery
> is at-most-once in any case (because network, and no re-delivery – unless
> you use AtLeastOnceDelivery or do it yourself). So yeah, they're protecting
> the receiver, nothing more - it's not a full-blown flow-control mechanism
> just an overflow protection.
>
> In that sense, they stick to what is core to Akka – messages may be
> dropped.
> Replying a NACK ("hey, please slow down") on each dropped message in such
> mailbox may sound interesting,
> but in practice often you'd rather get back ACKs and base your sending of
> data on those I think.
>
> A NACKing mailbox is not something we have built in. It's something you
> could write though (you can write a mailbox).
>
> --
> Cheers,
> Konrad 'ktoso’ Malawski
> Akka <http://akka.io> @ Typesafe <http://typesafe.com>
>
> On 28 December 2015 at 17:24:24, Jochen Mader ([email protected]
> <javascript:>) wrote:
>
> Before I start: I am perfectly aware of Reactive Streams and it is what I
> am currently using. I still use bounded mailboxes to prevent human error
> from sneaking through.
>
> With the current implementation of bounded mailboxes there is no way that
> either consumer or producer get to know if the mailbox is full or filling
> up.
> Overflow is redirected directly to Dead Letters with neither of them being
> informed.
> While preventing the crash of the system with an OOM it also feels like a
> missed opportunity for throttling.
> Are they just there to prevent OOMs or am I missing something in the API?
> --
> >>>>>>>>>> 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] <javascript:>.
> To post to this group, send email to [email protected]
> <javascript:>.
> Visit this group at https://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>
>
--
>>>>>>>>>> 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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
