Akkaによるbatch request作り方 ref: http://qiita.com/dtaniwaki/items/fc11b503ce0e27e52516

file0.scala

case class BatchTriggerTick()

file1.scala

class PusherActor(config: Config = ConfigFactory.load()) extends Actor {
  // ...

  system.scheduler.schedule(
    1000 milliseconds,
    1000 milliseconds,
    self,
    BatchTriggerTick()))

  // ...
}

file2.scala

class PusherActor(config: Config = ConfigFactory.load()) extends Actor {
  // ...

  protected val batchTriggerQueue = Queue[BatchTriggerMessage]()

  override def receive: Receive = {
    case trigger: BatchTriggerMessage =>
      batchTriggerQueue.enqueue(trigger)
      true
    case BatchTriggerTick() =>
      val triggers = batchTriggerQueue.dequeueAll { _ => true }
      triggers.grouped(batchNumber) foreach { triggers =>
        pusher.trigger(triggers.map(BatchTriggerMessage.unapply(_).get)).map {
          case Success(_) => // Do Nothing
          case Failure(e) => logger.warn(e.getMessage)
        }
      }
      triggers.length
  }

  // ...
}