serverInitialize.scala

class ZookeeperService(hostInfo: HostInfo) 
  extends ClusterService with EmbeddedZookeeper with Logging {
    
  // For Standalone use the hostname, eg. localhost
  // For Replicated use hostname:port,hostname:port,...
  @Value("${zookeeperService.hosts:localhost}")
  var hosts: String = _  
  
  // This node's ZK server client port
  def clientPort: Int = hostInfo.appBasePort + 1
  
  def initialize() {
    val serverNames = genServerNames(hosts)

    if (isServerEnabled) {
      val serverStarter = configureServer(serverNames)
      startServer(serverStarter)
    } else {
      log.info("Embedded zookeeper server not enabled")
    }

    // Client startup
    val connectString = serverNames.hosts.mkString(",") 
    // ...
  }
  
  // ... see part 1
}