Auto Updating Caching System - CacheActor.scala

CacheActor.scala

abstract class CacheActor[V](cacheSystem: CacheSystem) 
    extends Actor with Logging {

  def findValueReceive: Receive = {
    case FindValue(params) => findValueForSender(params, sender)
  }

  def findValueForSender(params: Params, sender: ActorRef) {
    val key = params.cacheKey
    val elem = cache.get(key)

    if (elem != null) {
      sender ! elem.getObjectValue.asInstanceOf[V]
    } else {
      // Implicit ExecutionContext for future
      import CacheActor._ 
      Future { findObject(params) } pipeTo sender
    }
  }

  def findObject(params: Params): Option[V] = {
    cacheSystem.findObjectForCache(params.cacheKey, cache, 
                                   finder(params))
  }

  // Provided by subclasses
  val cache: Cache
  def finder(params: Params): () => V
}