A simple example for an AMPS subscriber

AMPS Subscriber

import com.crankuptheamps.client.Client;
import com.crankuptheamps.client.exception.AMPSException;
import scala.collection.JavaConverters._

object Subscriber extends App {

  val client = new Client("subscribe")

  try {
    client.connect("tcp://127.0.0.1:9007/amps/json")
    client.logon()

    val messageStream = client.subscribe("messages").iterator().asScala
    messageStream.foreach(message => println(message.getData))
  } catch {
    case ampsException: AMPSException => println(s"Caught exception: ${ampsException.getMessage}")
  }
}