= statsd: honor the max-packet-size setting and include newline char on multi-metric packets

1 files changed, 3 insertions, 4 deletions

diff --git a/kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricTranslator.scala b/kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricTranslator.scala
index 2cf672b8..2ef41c6d 100644
--- a/kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricTranslator.scala
+++ b/kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricTranslator.scala
@@ -29,7 +29,7 @@ class StatsDMetricTranslator extends Actor {
   def receive = {
     case TickMetricSnapshot(from, to, metrics) ⇒
       val translatedMetrics = metrics.collect {
-        case (am @ ActorMetrics(_), snapshot: ActorMetricSnapshot) => transformActorMetric(am, snapshot)
+        case (am @ ActorMetrics(_), snapshot: ActorMetricSnapshot) ⇒ transformActorMetric(am, snapshot)
       }
 
       metricSender ! StatsD.MetricBatch(translatedMetrics.flatten)
@@ -42,9 +42,9 @@ class StatsDMetricTranslator extends Actor {
     roll(timeInMailboxKey, snapshot.timeInMailbox, StatsD.Timing) ++ roll(processingTimeKey, snapshot.processingTime, StatsD.Timing)
   }
 
-  def roll(key: String, snapshot: MetricSnapshotLike, metricBuilder: (String, Double, Double) => StatsD.Metric): Vector[StatsD.Metric] = {
+  def roll(key: String, snapshot: MetricSnapshotLike, metricBuilder: (String, Double, Double) ⇒ StatsD.Metric): Vector[StatsD.Metric] = {
     val builder = Vector.newBuilder[StatsD.Metric]
-    for(measurement <- snapshot.measurements) {
+    for (measurement ← snapshot.measurements) {
       val samplingRate = 1D / measurement.count
       val scaledValue = Scale.convert(snapshot.scale, Scale.Milli, measurement.value)
       builder += metricBuilder.apply(key, scaledValue, samplingRate)
@@ -53,7 +53,6 @@ class StatsDMetricTranslator extends Actor {
     builder.result()
   }
 
-
 }
 
 object StatsDMetricTranslator {