gistfile1.scala

/* Yesterday */
case object DurablyFlushUpdates extends EmptyMessage
object DurablyFlushUpdatesMaterializer 
  extends EmptyMessageMaterializer { 
   def createMessage = DurablyFlushUpdates 
}

/* Today */
case class DurablyFlushUpdates(replicaCount: Int = 2) 
  extends NameValueMessage {
    def toNameValuePairs = List(
      ("replicaCount", replicaCount)
    )
}
object DurablyFlushUpdatesMaterializer 
  extends SingleValueMaterializer[Int]("replicaCount") {
    def createMessage(value: Option[Int]) = {
      DurablyFlushUpdates(value.getOrElse(2))
    }
}