scala - 如何避免由于 akka actor 中的锁定超时而丢失消息?

标签 scala akka actor

波纹管是以下构建日志中的一行:https://travis-ci.org/plokhotnyuk/actors/jobs/4088637/#L630

[WARN] [01/11/2013 12:26:04.908] [Thread-47] [akka://system/user/$t] dropping message of typeclass com.github.plokhotnyuk.actors.Message due to lock timeout

是否有能力配置此超时或完全避免锁定?

测试代码在这里: https://github.com/plokhotnyuk/actors/blob/master/src/test/scala/com/github/plokhotnyuk/actors/AkkaActorSpec.scala

最佳答案

此超时可在 akka.actor.unstarted-push-timeout 中配置,但如果您要创建许多顶级 Actor (system.actorOf),您应该创建 Actor 是另一个 Actor 的 child (context.actorOf)。

关于scala - 如何避免由于 akka actor 中的锁定超时而丢失消息?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/14279185/

相关文章:

scala - 使用流建模多个函数调用(以安全的 FP 方式)

postgresql - 如何在 slick 3 的 DBIOAction 组合中使用 Future?

scala - 可以使用 actor 'threadless' 在 Scala 中制作生产者/消费者对象(没有接收...)?

Scala Actors 而不是 Java Futures

scala - 在 Scala 中唯一标识 Actor

Scala 中匿名类的 Java 风格 Lambda 表达式

scala - NoClassDefFoundError:SparkSession-即使构建正常

http - 如何在 Spray 框架中获取传入 IP 地址

scala - 在 Akka 中创建 actor 的首选方式是什么?

java - Akka-testkit "future.isCompleted"检查