Consumer.scala

trait Consumer {
  def name: String
  def await(msg: Message): Future[Unit]
  def close(): Unit
}

Producer.scala

trait Publisher[V <: Message] {
  def name: String
  def send(value: V): Future[Unit]
  def close(): Unit
}