From cbcc0381edf5800f280ba9b1fa801ff6bdc969e0 Mon Sep 17 00:00:00 2001 From: Evan Langlais Date: Wed, 6 Mar 2019 16:43:26 -0500 Subject: [PATCH] Modifying body string --- .../scala/com/powerpanel/kso/OpenTSDBOutput.scala | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala b/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala index bdad99b..d09faea 100644 --- a/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala +++ b/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala @@ -50,17 +50,16 @@ class OpenTSDBOutput extends Serializable { val region = generatorData.getRegion(); val state = generatorData.getState; val pstring = f"""{ - | "metric": "$metric", - | "value": "$value", - | "timestamp": $timestamp, - | "tags": {"generator": $generator_id, "state": "$state", "region": "$region"} - |},"""; - pstring.stripMargin; + "metric": "$metric", + "value": $value, + "timestamp": $timestamp, + "tags": {"generator": $generator_id, "state": "$state", "region": "$region"} + },""".stripMargin; body = body.concat(pstring); } } body = body.concat("]"); - Holder.logger.info(body); + Holder.logger.info("Post body: " + body); var openTSDBUrl = "http://" + opentsdbIP + "/api/put" try { val httpClient = new DefaultHttpClient()