actor

    0热度

    1回答

    我想通过以下方式运行Akka Actor的receive method: def receive = { case x: collection.mutable.Map[String, collection.mutable.Map[String,Float]]=> insertValueIntoTable(x) } 我能没有问题,编译这个,但我得到错误: Error

    0热度

    2回答

    我有一个使Http调用到外部服务的actor。有时服务会使用Http 404进行响应,并且有时也会出现http连接错误。再次重试时,这些都会消失。 什么是由演员重试请求的最佳方式。 什么,我能想到的是 使用主管战略和重启演员 使用在重试HTTP调用演员递归方法, 最大重试次数次 哪一个是正确的方法,1或2.我认为方法1对于像重试一个Http调用那样简单的事情来说是过度的。请分享你的建议。

    1热度

    3回答

    我试图在远程主机上创建Akka Actor。 继官方文档之后,我创建了一个远程Actor系统解析application.config文件,然后创建一个新的actor。 这是我的代码: public static void main(String[] args) { Config config = ConfigFactory.parseFile(new File("application

    0热度

    1回答

    我制作了可靠的服务应用程序,该应用程序在本地群集上完美工作。 它有1个无状态服务和1个演员服务,都使用服务远程处理。 终点都不在这些服务(仅端点名称)和服务都使用默认的监听器定义(没有CreateServicesListeners覆盖) 客户端应用程序是使用远程服务与应用(ActorProxy和ServiceProxy),以comunicate一个控制台应用程序。 现在我想将它部署在Azure群集

    1热度

    1回答

    我有一个舞台和它的大小为200x200的演员。我需要演员捕捉触摸事件来做一些计算。但问题在于触摸事件只有在触及到演员边界时触发。我如何获得触摸屏幕任何区域的事件,但在演员的课堂内处理? public class MyActor extends Actor { public MyActor() { setBounds(100f, 100f, 200f, 200f); ad

    0热度

    2回答

    我创建了一些演员,它应该用自己的消息包装所有传入的消息并进一步转发它们。 不幸的是,我没有任何用户消息的公共基类,所以我打算用Object.class来捕捉它们。 现在我不确定阿卡是否可以将自己的消息发送给演员。我不想偶尔转发一些发给我的封装演员的系统消息。

    0热度

    1回答

    我正在学习如何使用context.become来控制我的演员状态的行为,我使用这个代码: class MyActor extends Actor { override def receive: Receive = { println("Happens here") active(Set.empty) } def active(isInSet:

    1热度

    2回答

    我有这个不是重播的消息: val receive = beforeLoadReceive // my default receive override def preStart(): Unit = { doSomeLoadFromDB() unstashAll() context.become(connectedReceive) println("I a

    0热度

    1回答

    我试图创建一个Actor指针指向另一个Actor对象,像这样删除: Actor other = Actor(); Actor* ptr = &other; 然后,当我尝试delete ptr,它导致运行时错误: Program.exe has triggered a breakpoint 但是,当我创建一个新的Actor而不是分配给ptr的other参考,我可以放心地delete它没有任何错

    0热度

    1回答

    我们正在考虑将服务结构演员定时器用于某种TTL管理服务。它有可能有100个成千上万的演员定时器。我们担心这么多演员定时器一次只能运行一段时间,但似乎没有任何关于演员定时器的性能影响或潜在机制的文档。任何指导将不胜感激。