package couchdb.changes

import akka.actor._
import spray.http.Uri

object LoggingActor extends Actor with ActorLogging {
  log.info("Initializing LoggingActor")
  def receive: Receive = {
    case x => log.info("Received {}", x)
  }
}

case object Start

object Example extends App {

  val system = ActorSystem()
  val stream = system.actorOf(Props(new ChangesStreamActor(
    system.actorOf(Props(LoggingActor)))))

  stream ! Start
}

import com.wacai.config.annotation._
import scala.concurrent.duration._

@conf trait settings extends Configurable {
  val couchConf = new {
    val url = "http://localhost:5984/example"
    val heartbeat = 5 seconds
    val reconnect = 45 seconds
  }
}

// vim: set ts=2 sw=2 et: