gistfile1.scala

trait KinjaMessage extends java.io.Serializable {
  def toByteArray: Array[Byte]
}

trait NameValueMessage extends KinjaMessage {
  def toNameValuePairs: TraversableOnce[(String, Any)]

  override def toByteArray: Array[Byte] = {

    val nvBuilder = NameValueSeq.newBuilder()

    toNameValuePairs.foreach(nv => {
      add(nv, nvBuilder)
    })

    nvBuilder.build().toByteArray
  }
}

trait KinjaMessageMaterializer {
  def fromByteArray(bytes: Array[Byte]): KinjaMessage
}