Конечная точка, получающая список объектов из иерархии

Предполагая, что вы используете одну библиотеку сериализации json по умолчанию в akka-http — spray-json — вы весьма ограничены в объединении нескольких программ чтения json (согласно официальная страница и исходный код). Лучшее, что вы можете сделать, это написать вручную какой-нибудь форматтер (или просто ридер) для Message.

import spray.json.DefaultJsonProtocol._
import spray.json._

implicit val smsFormat: JsonFormat[SMS] = jsonFormat2(SMS)
implicit val emailFormat: JsonFormat[Email] = jsonFormat2(Email)

implicit val messageFormat: JsonFormat[Message] = new JsonFormat[Message] {
  override def read(json: JsValue): Message = json match {
    case sms@JsObject(_) if sms.fields.contains("numFrom") => smsFormat.read(sms)
    case email@JsObject(_) if email.fields.contains("emailFrom") => emailFormat.read(email)
    case _ => deserializationError("object expected")
  }

  override def write(obj: Message): JsValue = obj match {
    case sms: SMS => sms.toJson
    case email: Email => email.toJson
    case _ => throw new RuntimeException("Houston, we have a problem")
  }
}

Я бы также посоветовал вам взглянуть на библиотеку circe, чей код гораздо более компонуемый. Его также легко интегрировать с akka-http.

Обновление 1: (после указания точной библиотеки):

Есть несколько вариантов:

1. объединить несколько декодеров

     import io.circe.generic.auto._
     import io.circe.{Decoder, HCursor}
   
     class CirceExample extends App {
   
       sealed trait Message
   
       case class SMS(numFrom: String, message: String) extends Message
   
       case class Email(emailFrom: String, message: String) extends Message
   
       val smsDecoder = implicitly[Decoder[SMS]]
       val emailDecoder = implicitly[Decoder[Email]]
   
       val messageDecoder: Decoder[Message] = (c: HCursor) => smsDecoder(c).orElse(emailDecoder(c))
     }
   

   Этого легко добиться, потому что результатом декодирования Decoder будет Either.

2. Создайте собственный декодер, который явно проверяет наличие необходимых полей — документация. Этот подход немного похож на предыдущий пример с spray-json.

обновление 2:

import cats.syntax.functor._
import io.circe.Decoder
import io.circe.generic.auto._
import io.circe.parser._

object CirceExample extends App {

  sealed trait Message

  case class SMS(numFrom: String, message: String) extends Message

  case class Email(emailFrom: String, message: String) extends Message

  implicit val messageDecoder: Decoder[Message] = List[Decoder[Message]](Decoder[SMS].widen, Decoder[Email].widen).reduceLeft(_ or _)
  // or without list..
  //implicit val messageDecoder: Decoder[Message] = Decoder[SMS].widen or Decoder[Email].widen

  val payload = """[{"emailFrom":"a","message":"b"}]"""
  val result = decode[List[Message]](payload)
  println(result)
}

Здесь есть несколько шагов, поэтому я постараюсь не усложнять.

Во-первых, нам нужно определить кодировщики и декодеры для Email и n SMS:

sealed trait Message
@JsonCodec case class SMS(numFrom: String, message:String) extends Message
@JsonCodec case class Email(emailFrom: String, message: String) extends Message

object Message {
  implicit val decodeA: Decoder[Message] = Decoder[SMS].map[Message](identity).or(Decoder[Email].map[Message](identity))
  implicit val encodeA: Encoder[Message] = Encoder.instance {
    case b @ SMS(_, _) => b.asJson
    case c @ Email(_, _) => c.asJson
  }
}

Я нашел это в этой ссылке, после всех предыдущих попыток с этой нить не работала.

Продолжим. Мы должны найти это в отдельном модуле. В противном случае получаем enable macro paradise to expand macro annotations ошибку. После прочтения этого поста, в котором в основном объясняется, что макросы нельзя объявлять и использовать в одном и том же модуле, я переместил указанное выше код в другой модуль, который заставил код компилироваться.

Имея отдельный модуль с приведенным выше кодом, нам нужно определить новый модуль, чтобы он зависел от первого.

Теперь в последнем модуле нам нужно сначала импортировать:

import de.heikoseeberger.akkahttpcirce.FailFastCirceSupport.unmarshaller

то мы можем создать маршрут:

val routes = pathPrefix("somePath" / Segment) { someData =>
  post {
    entity(as[List[Message]]) { listOfMessages =>
      // some code here ...
      complete(StatusCodes.OK)
    }
  }
}