cleanup cleanup cleanup

1 files changed, 0 insertions, 129 deletions

diff --git a/kamon-core/src/main/scala/test/PingPong.scala b/kamon-core/src/main/scala/test/PingPong.scala
deleted file mode 100644
index 8808e4bf..00000000
--- a/kamon-core/src/main/scala/test/PingPong.scala
+++ /dev/null
@@ -1,129 +0,0 @@
-package test
-
-import akka.actor._
-import java.util.concurrent.atomic.AtomicLong
-import kamon.Tracer
-import spray.routing.SimpleRoutingApp
-import akka.util.Timeout
-import spray.httpx.RequestBuilding
-import scala.concurrent.{Await, Future}
-
-object PingPong extends App {
-  import scala.concurrent.duration._
-  val counter = new AtomicLong
-
-  val as = ActorSystem("ping-pong")
-  import as.dispatcher
-
-  Tracer.start
-
-  for(i <- 1 to 64) {
-    val pinger = as.actorOf(Props[Pinger])
-    val ponger = as.actorOf(Props[Ponger])
-
-    for(_ <- 1 to 256) {
-      pinger.tell(Pong, ponger)
-    }
-  }
-
-  as.scheduler.schedule(1 second, 1 second) {
-    println("Processed: " + counter.getAndSet(0))
-  }
-}
-
-case object Ping
-case object Pong
-
-class Pinger extends Actor {
-  def receive = {
-    case Pong => {
-      sender ! Ping
-      PingPong.counter.incrementAndGet()
-    }
-  }
-}
-
-class Ponger extends Actor {
-  def receive = {
-    case Ping => {
-      sender ! Pong; PingPong.counter.incrementAndGet()
-    }
-  }
-}
-
-
-object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuilding {
-  import scala.concurrent.duration._
-  import spray.client.pipelining._
-  import akka.pattern.ask
-
-  implicit val system = ActorSystem("test")
-  import system.dispatcher
-
-  implicit val timeout = Timeout(30 seconds)
-
-  val pipeline = sendReceive
-  val replier = system.actorOf(Props[Replier])
-
-  startServer(interface = "localhost", port = 9090) {
-    get {
-      path("test"){
-        complete {
-          pipeline(Get("http://www.despegar.com.ar")).map(r => "Ok")
-        }
-      } ~
-      path("reply" / Segment) { reqID =>
-        complete {
-          if (Tracer.context().isEmpty)
-            println("ROUTE NO CONTEXT")
-
-          (replier ? reqID).mapTo[String]
-        }
-      } ~
-      path("ok") {
-        complete("ok")
-      } ~
-      path("future") {
-        dynamic {
-          complete(Future { "OK" })
-        }
-      }
-    }
-  }
-
-}
-
-object Verifier extends App {
-
-  def go: Unit = {
-    import scala.concurrent.duration._
-    import spray.client.pipelining._
-    import akka.pattern.ask
-
-    implicit val system = ActorSystem("test")
-    import system.dispatcher
-
-    implicit val timeout = Timeout(30 seconds)
-
-    val pipeline = sendReceive
-
-    val futures = Future.sequence(for(i <- 1 to 500) yield {
-      pipeline(Get("http://127.0.0.1:9090/reply/"+i)).map(r => r.entity.asString == i.toString)
-    })
-    println("Everything is: "+ Await.result(futures, 10 seconds).forall(a => a == true))
-  }
-
-
-
-
-}
-
-class Replier extends Actor with ActorLogging {
-  def receive = {
-    case anything =>
-      if(Tracer.context.isEmpty)
-        log.warning("PROCESSING A MESSAGE WITHOUT CONTEXT")
-
-      sender ! anything
-  }
-}