MyService.scala

import com.yammer.metrics.Meter
import com.twitter.zookeeper.ZooKeeperClient
import com.boundary.ordasity.{Cluster, ClusterConfig, SmartListener}

class MyService {
  val config = new ClusterConfig("localhost:2181")
  val cluster = new Cluster("ServiceName", listener, config)

  val listener = new SmartListener {

    // Called after successfully joining the cluster.
    def onJoin(client: ZooKeeperClient) { } 

    // Do yer thang, mark that meter.
    def startWork(workUnit: String, meter: Meter) { }

    // Stop doin' that thang.
    def shutdownWork(workUnit: String) { }

    // Called after leaving the cluster.
    def onLeave() { }
  }

  cluster.join()
}