Spotlight for ConsistentHashingRouter

ConsistentHashingRouterSpotlight.scala

import akka.routing.ConsistentHashingRouter
import akka.routing.ConsistentHashingRouter.ConsistentHashMapping
import akka.actor.Actor
import akka.pattern.ask

case class Entry(key: String, value: String)

class Cache extends Actor {
  var cache = Map.empty[String, String]
 
  def receive = {
    case Entry(key, value) => cache += (key -> value)
    case key: String       => sender ! cache.get(key)
  }
}

def hashMapping: ConsistentHashMapping = {
  case Entry(key, _) => key
  case s: String     => s
}
val cache = system.actorOf(Props[Cache].withRouter(
  ConsistentHashingRouter(10, hashMapping = hashMapping)), 
  name = "cache")

cache ! Entry("hello", "HELLO")
cache ? "hello" onSuccess { case x => println(x) }