Make sure you have an EventSource HQ account.
Add the following dependency to your build.sbt:
libraryDependencies ++= Seq(
"com.github.synesso" %% "eshq" % "0.1"
)Make sure you have the sonatype OSS releases resolver configured:
resolvers ++= Seq(
"Sonatype OSS Releases" at "http://oss.sonatype.org/content/repositories/releases/"
)import com.github.synesso.eshq._
// create a client with your ESHQ credentials
val client = new EventSourceClient(Key("my-key"), Secret("my-secret"))
// open a channel and receive the channel data from ESHQ
val channelData: Future[String] = client.open(Channel("my-channel"))
// send an event to a channel as a String
client.send(Channel("my-channel"), """{"msg": "Hello, World!"}"""})
// send any reference as an event to a channel as JSON
case class WeatherAlert(temperature: Double, time: Date)
client.send(Channel("my-channel"), WeatherAlert(42.2, new Date))The EventSourceClient takes an optional serviceURL parameter, should it differ from the
default value of http://app.eventsourcehq.com
val client = new EventSourceClient(Key("a"), Secret("b"), new URL("http://non.default-ho.st"))
