def notify()

in client/src/main/scala/com/gu/anghammarad/Anghammarad.scala [46:54]


  def notify(notification: Notification, topicArn: String)
            (implicit executionContext: ExecutionContext): Future[String] = {
    val request = PublishRequest.builder()
      .topicArn(topicArn)
      .subject(notification.subject)
      .message(messageJson(notification.message, notification.sourceSystem, notification.channel, notification.target, notification.actions))
      .build()
     asScala(defaultClient.publish(request)).map(_.messageId)
  }