AWS Lambda, Publish an SNS Message — Scala

main.scala

package blahblah;

import scala.collection.JavaConverters._
import java.net.URLDecoder

import com.amazonaws.services.lambda.runtime.Context
import com.amazonaws.services.sns.AmazonSNSClient
import com.amazonaws.services.sns.model.PublishRequest
import java.io.{InputStream, OutputStream, PrintStream}

class Main {
  val topicArn = "arn:aws:sns:us-west-2:xxxxxxxxxxxx:some_topic"
  val snsClient = new AmazonSNSClient()
  snsClient.setRegion(Region.getRegion(Regions.US_WEST_2));
  
  // receive an event, and publish to SNS
  def scheduled(input: InputStream, output: OutputStream, context:Context): Unit = {
    val publishRequest = new PublishRequest(topicArn, item_url.toString)
    val publishResult = snsClient.publish(publishRequest)
    log(publishResult.getMessageId() + " >> " + item_url.toString)
  }
}