【发布时间】:2014-10-03 16:23:52
【问题描述】:
我有一个向自己发送消息的 akka 演员:
def receive = {
while (...) {
self ! "some message"
}
}
我想使用一个 Throttler 来控制这个 Actor 发送给自己的消息流。
val throttler = system.actorOf(Props(new TimerBasedThrottler(15 msgsPer (1.minute))))
throttler ! SetTarget(Some(self))
然后更改 while 循环以向限制器发送消息:
while (...) {
throttler ! "some message"
}
问题是我不知道如何从演员内部访问“系统”来创建节流器。这个怎么做?有没有更好的办法?
【问题讨论】:
标签: scala akka actor throttling