fix aggregator sequencer

This commit is contained in:
Thibault Duplessis 2015-07-28 17:35:58 +02:00
parent a46603975e
commit 1123c5e5f0
4 changed files with 6 additions and 6 deletions

View file

@ -31,7 +31,7 @@ final class Env(
lazy val aggregator = new Aggregator(
api = statApi,
sequencer = system.actorOf(Props(classOf[lila.hub.Sequencer], 5 minutes)))
sequencer = system.actorOf(Props(classOf[lila.hub.Sequencer], None)))
}
object Env {

View file

@ -6,9 +6,9 @@ import scala.util.Try
import akka.actor._
final class Sequencer(receiveTimeout: FiniteDuration) extends Actor {
final class Sequencer(receiveTimeout: Option[FiniteDuration]) extends Actor {
context setReceiveTimeout receiveTimeout
receiveTimeout.foreach(context.setReceiveTimeout)
private def idle: Receive = {
@ -41,7 +41,7 @@ final class Sequencer(receiveTimeout: FiniteDuration) extends Actor {
promiseOption.foreach(_.success(()))
self ! Done
}
case x => play.api.Logger("Sequencer").warn(s"Unsupported message $x")
case x => logwarn(s"[Sequencer] Unsupported message $x")
}
}
}

View file

@ -108,7 +108,7 @@ final class Env(
private[simul] val simulColl = db(CollectionSimul)
private val sequencerMap = system.actorOf(Props(ActorMap { id =>
new Sequencer(SequencerTimeout)
new Sequencer(SequencerTimeout.some)
}), name = SequencerMapName)
private lazy val simulCleaner = new SimulCleaner(repo, api, socketHub)

View file

@ -92,7 +92,7 @@ final class Env(
}), name = SocketName)
private val sequencerMap = system.actorOf(Props(ActorMap { id =>
new Sequencer(SequencerTimeout)
new Sequencer(SequencerTimeout.some)
}), name = SequencerMapName)
private val organizer = system.actorOf(Props(new Organizer(