aboutsummaryrefslogtreecommitdiff
path: root/kamon-newrelic/src/main/scala/kamon/newrelic/Agent.scala
diff options
context:
space:
mode:
authorIvan Topolnak <itopolnak@despegar.com>2014-02-06 10:23:34 -0300
committerIvan Topolnak <itopolnak@despegar.com>2014-02-06 10:48:34 -0300
commit679b0dcb8e715a2e7e3226b05755931453cf510d (patch)
treeb9bd0803ef49cebc736f54862789e5680e09c9e5 /kamon-newrelic/src/main/scala/kamon/newrelic/Agent.scala
parent522a12c90788c402a364407e146d302e6519a3da (diff)
downloadKamon-679b0dcb8e715a2e7e3226b05755931453cf510d.tar.gz
Kamon-679b0dcb8e715a2e7e3226b05755931453cf510d.tar.bz2
Kamon-679b0dcb8e715a2e7e3226b05755931453cf510d.zip
minor cleanup before relasing 0.0.13
Diffstat (limited to 'kamon-newrelic/src/main/scala/kamon/newrelic/Agent.scala')
-rw-r--r--kamon-newrelic/src/main/scala/kamon/newrelic/Agent.scala4
1 files changed, 1 insertions, 3 deletions
diff --git a/kamon-newrelic/src/main/scala/kamon/newrelic/Agent.scala b/kamon-newrelic/src/main/scala/kamon/newrelic/Agent.scala
index a73f390a..299773e4 100644
--- a/kamon-newrelic/src/main/scala/kamon/newrelic/Agent.scala
+++ b/kamon-newrelic/src/main/scala/kamon/newrelic/Agent.scala
@@ -49,7 +49,6 @@ class Agent extends Actor with RequestBuilding with ResponseTransformation with
"marshal_format" -> "json",
"protocol_version" -> "12")
-
def receive = {
case Initialize(runId, collector) ⇒
log.info("Agent initialized with runID: [{}] and collector: [{}]", runId, collector)
@@ -77,12 +76,11 @@ class Agent extends Actor with RequestBuilding with ResponseTransformation with
}
import AgentJsonProtocol._
- val compressedPipeline: HttpRequest ⇒ Future[HttpResponse] = logRequest(println(_)) ~>encode(Deflate) ~> sendReceive ~> logResponse(println(_))
+ val compressedPipeline: HttpRequest ⇒ Future[HttpResponse] = encode(Deflate) ~> sendReceive
val compressedToJsonPipeline: HttpRequest ⇒ Future[JsValue] = compressedPipeline ~> toJson
def toJson(response: HttpResponse): JsValue = response.entity.asString.asJson
-
def selectCollector: Future[String] = {
val query = ("method" -> "get_redirect_host") +: baseQuery
val getRedirectHostUri = Uri("http://collector.newrelic.com/agent_listener/invoke_raw_method").withQuery(query)