RMQ-stuff.scala

import play.api.libs.json.{Json, Writes}

trait RabbitMessage {
  val command: String
}

object ActivateMessage {
  implicit val tjs: Writes[ActivateMessage] = Json.writes[ActivateMessage]
}

case class ActivateMessage(Id:String, command:String="activate") extends RabbitMessage


def publishToRMQ[T <: RabbitMessage](deviceId: String, toRMQRabbitMessage: T)(implicit writer: Writes[T]) =
  publishString(writer.writes(toRMQRabbitMessage).toString, getToRMQRoutingKey(deviceId, toRMQRabbitMessage.command))


sealed case class SendMessage[T <: RabbitMessage](Id: String, message: T)(implicit writer: Writes[T])

when(Idle){
  case Event(SendMessage(Id, message)(writes),_) => {
    log.info(s"sending RMQ message: $message")
    publishToRMQ(Id, message)(writes)
    goto(AwaitRMQResponse$) using AwaitRMQResponseData(sender)
  }
}