BorerAkkaSerializer.scala

class BorerAkkaSerializer() extends Serializer with Codecs {

  override def identifier: Int          = 19923
  override def includeManifest: Boolean = true

  override def toBinary(o: AnyRef): Array[Byte] = o match {
    case x: Zoo     => Json.encode(x).toByteArray
    case _ =>
      throw new RuntimeException(s"does not support encoding of $o")
  }

  override def fromBinary(bytes: Array[Byte], manifest: Option[Class[_]]): AnyRef = {
    if (classOf[Zoo].isAssignableFrom(manifest.get))
      Json.decode(bytes).to[Zoo].value
    else
      throw new RuntimeException(s"does not support decoding of ${manifest.get}")
  }
}