Fix Flume UDP source delimiter error (#61)

awegrzyn · web-flow · commit 5e78256570f5 · 2018-07-06T15:23:18.000+02:00
diff --git a/src/Backends/Flume.cxx b/src/Backends/Flume.cxx
@@ -50,7 +50,7 @@ void Flume::send(std::vector<Metric>&& metrics)
   std::string flumeMetrics = "";
   for (auto& metric : metrics) {
     flumeMetrics += metricToJson(metric);
-    flumeMetrics += "\n";
+    flumeMetrics += '\n';
   }
   mTransport->send(std::move(flumeMetrics));
 }
@@ -84,7 +84,9 @@ std::string Flume::metricsToJson(std::string measurement, std::vector<Metric>&&
 
 void Flume::send(const Metric& metric)
 {
-    mTransport->send(metricToJson(metric));
+    std::string toSend = metricToJson(metric);
+    toSend += '\n';
+    mTransport->send(std::move(toSend));
 }
 
 inline unsigned long Flume::convertTimestamp(const std::chrono::time_point<std::chrono::system_clock>& timestamp)

Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,7 @@ void Flume::send(std::vector<Metric>&& metrics)`
`50`	`50`	`std::string flumeMetrics = "";`
`51`	`51`	`for (auto& metric : metrics) {`
`52`	`52`	`flumeMetrics += metricToJson(metric);`
`53`		`- flumeMetrics += "\n";`
	`53`	`+ flumeMetrics += '\n';`
`54`	`54`	`}`
`55`	`55`	`mTransport->send(std::move(flumeMetrics));`
`56`	`56`	`}`
`@@ -84,7 +84,9 @@ std::string Flume::metricsToJson(std::string measurement, std::vector<Metric>&&`
`84`	`84`
`85`	`85`	`void Flume::send(const Metric& metric)`
`86`	`86`	`{`
`87`		`- mTransport->send(metricToJson(metric));`
	`87`	`+ std::string toSend = metricToJson(metric);`
	`88`	`+ toSend += '\n';`
	`89`	`+ mTransport->send(std::move(toSend));`
`88`	`90`	`}`
`89`	`91`
`90`	`92`	`inline unsigned long Flume::convertTimestamp(const std::chrono::time_point<std::chrono::system_clock>& timestamp)`