mkhq

package test

import akka.remote.{RemoteClient, RemoteNode, RemoteServer}
import akka.actor.{Actor, ActorRef}
import akka.serialization.RemoteActorSerialization
import akka.actor.Actor.actorOf

import org.specs._

import java.util.concurrent.{CountDownLatch, TimeUnit}

mkhq

test.akka

import akka.actor.Actor
import akka.actor.Actor.actorOf

import org.specs._

object ActorMatchSpec extends Specification {
  "actor match" should {
    "match non-exhaustive" in {

mkhq

import akka.remoteinterface.RemoteSupport
import akka.remote.netty.NettyRemoteSupport
import akka.actor.Actor.actorOf
import akka.actor.{Actor}

import org.specs._

import java.util.concurrent.{CountDownLatch, TimeUnit}

object ServiceState {

mkhq

import com.twitter.zookeeper.ZooKeeperClient
import org.apache.zookeeper.CreateMode
import java.util.UUID

object PrimaryBootstrap {
  def main(args:Array[String]) {
    val path = args(0)

    val zk = new ZooKeeperClient("localhost:2181")
    zk.create(path, null, CreateMode.PERSISTENT)

mkhq

#!/bin/bash

DAEMON_PATH=/opt/kafka/
PATH=$PATH:$DAEMON_PATH/bin

# See how we were called.
case "$1" in
  start)
        # Start daemon.
        echo "Starting Zookeeper";

mkhq

#!/bin/bash

# An set of disks to ignore from partitioning and formatting
BLACKLIST="/dev/sda|/dev/sdb"
# Base directory to hold the data* files
DATA_BASE="/media"

usage() {
    echo "Usage: $(basename $0) <new disk>"
}