草庐IT

ActorSelection

全部标签

java - 我如何检查 Akka Actor 是否存在(akka 2.2)?

我有一个java对象,它不是使用actorSelection(Path))从Actor系统中选择Actor的Actor。系统中可能不存在所选参与者。在JavaApi中,ActorSelection不存在ask(),因此我无法向Actor选择发送和识别消息并使用响应的发送者。我试图通过Actor选择将消息发送给Actor然后对死信作出react来解决问题。但我没有收到任何死信。如何检查ActorSelectionActor是活着还是不存在?ActorSystemsystem=ActorSystem.create("test");//createtestactorsystem.actorO

java - 我如何检查 Akka Actor 是否存在(akka 2.2)?

我有一个java对象,它不是使用actorSelection(Path))从Actor系统中选择Actor的Actor。系统中可能不存在所选参与者。在JavaApi中,ActorSelection不存在ask(),因此我无法向Actor选择发送和识别消息并使用响应的发送者。我试图通过Actor选择将消息发送给Actor然后对死信作出react来解决问题。但我没有收到任何死信。如何检查ActorSelectionActor是活着还是不存在?ActorSystemsystem=ActorSystem.create("test");//createtestactorsystem.actorO

docker - 使用 Docker Ask 的 Yahoo 管理器错误在 [ActorSelection [Anchor(akka ://kafka-manager-system/),) 上超时

为了复制这个问题,在下面的yaml文件上运行dockerrunzookeeper然后docker-composeup。我正在使用zookeeper最新图像wurstmeister/kafka:0.9.0.0-1和sheepkiller/kafka-manager:latest.我运行docker-composeup并最终让它工作,但现在我收到以下错误:我搜索了git和stackoverflow无济于事。在我保存集群之前,一切看起来都很好。在我得到的Kafka日志中:[warn]o.a.z.ClientCnxn-Session0x0forservernull,unexpectederro