akka/akka-core

Pluggable buffer for network actors

开放

#17,766 创建于 2015年6月18日

 (1 条评论) (0 个反应) (0 位负责人)Scala (3,547 个派生)batch import
1 - triagedhelp wantedt:cluster-tools

仓库指标

星标
 (13,277 个星标)
PR 合并指标
 (PR 指标待抓取)

描述

Cluster singleton and cluster sharding both uses an internal buffer (and not the mailbox) for when the remote actor is not available. It would be nice if that buffer was pluggable (as the mailbox were).

Use-cases:

  • If you have a retry mechanism, you may want to throw away new messages when the buffer is full. That way the retry will not effect message ordering too much.
  • If you send updates for some entries, and are only interested in the latest update for each entry, you could implement a buffer that throws away all out-of-date information and only tries to send the latest info.
  • Maybe you don't want to change the behavior when the buffer is full, you just want to notify someone (logging, back-pressure etc).

What do you think?

贡献者指南