libraryDependencies += "space.divergence" % "beanstalker_2.11" % "0.0.1"

libraryDependencies += "space.divergence" %% "beanstalker" % "0.0.1"

val client = Client(requestTube = "request-tube", 
                    responseTube = "response-tube", 
                    host = "127.0.0.1", 
                    port = 11300)                                       // Create client

client.send("message".getBytes)                                         // Send request
  .onSuccess {                                                          // Handle response
    case data: Array[Byte] => println("Response: " + new String(data))   
  }

def onRequest(data: Array[Byte]): Future[Array[Byte]] =                 // Request handler
  Future {
    println("Request: " + new String(data))
    data
  }

val server = Server(requestTube = "request-tube", 
                    responseTube = "response-tube", 
                    host = "127.0.0.1",
                    port = 11300, 
                    processor = onRequest)                              // Create Server

sbt test

sbt "it:test-only space.divergence.beanstalker.ClientServerTest -- -DreqTube=req -DresTube=res -Dhost=127.0.0.1 -Dport=11300 -Dload=1000 -Dttp=1"