Skip to content

Commit

Permalink
Fix example code.
Browse files Browse the repository at this point in the history
  • Loading branch information
C. Scott Andreas committed Oct 22, 2012
1 parent 70ac8f7 commit 204da4f
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions Example.scala
Expand Up @@ -18,8 +18,8 @@ import java.util.Random
import java.util.concurrent.CountDownLatch
import com.boundary.ordasity.{Cluster, ClusterConfig, SmartListener}
import com.codahale.logula.Logging
import com.yammer.metrics.Meter
import com.twitter.zookeeper.ZooKeeperClient
import com.yammer.metrics.scala.Meter
import com.twitter.common.zookeeper.ZooKeeperClient
import java.util.concurrent.{ScheduledThreadPoolExecutor, TimeUnit, ScheduledFuture}
import java.util.{HashMap, TimerTask}

Expand All @@ -31,7 +31,8 @@ val pool = new ScheduledThreadPoolExecutor(1)

val futures = new HashMap[String, ScheduledFuture[_]]

val config = new ClusterConfig("localhost:2181").
val config = new ClusterConfig().
setHosts("localhost:2181").
setAutoRebalance(true).
setRebalanceInterval(15).
useSmartBalancing(true).
Expand Down

0 comments on commit 204da4f

Please sign in to comment.