diff --git a/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala b/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala
index c4b360d..71550ff 100644
--- a/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala
+++ b/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala
@@ -14,8 +14,6 @@ import org.json4s.JsonDSL._
 import scala.collection.JavaConversions._
 
 class OpenTSDBOutput extends Serializable {
-
-  private[this] val logger = Logger.getLogger(getClass().getName());
   
   def putOpentsdb[T](opentsdbIP: String, stream: DStream[DataPackage]) = {
     stream.mapPartitions(partition => {
@@ -53,13 +51,11 @@ class OpenTSDBOutput extends Serializable {
                     |        "timestamp": $timestamp,
                     |        "tags": {"generator": $generator_id, "state": "$state", "region": "$region"}
                     |},""";
-                body.concat(pstring);
+                pstring.stripMargin;
+                body = body.concat(pstring);
              }
           }
-          body.concat("]");
-          
-          logger.info(body);
-          
+          body = body.concat("]");
           var openTSDBUrl = "http://" + opentsdbIP + "/api/put"
           try {
                 val httpClient = new DefaultHttpClient()