def notify()

in client/src/main/scala/com/gu/anghammarad/Anghammarad.scala [64:72]


  def notify(notification: Notification, topicArn: String, client: SnsAsyncClient)
            (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(client.publish(request)).map(_.messageId)
  }