Main.scala

package slack.rtm

import slack.api.BlockingSlackApiClient
import scala.concurrent.duration._
import akka.actor.{ ActorSystem, Props }

import SlackRtmConnectionActor._

object Main extends App {
  val token = "<token>"
  implicit val system = ActorSystem("test")
  val client = BlockingSlackApiClient(token)
  val state = RtmState(client.startRealTimeMessageSession())
  val actor = system.actorOf(Props(new SlackRtmConnectionActor(token, state, 10.seconds)))

  val handler = MessageHandlerActor(println)
  actor ! AddEventListener(handler)
}