Just close Riemann client on send metrics failure

Signed-off-by: Eugene Chupriyanov <e.chupriyanov@cpm.ru>
influxdata · Apr 18, 2016 · c237e6a · c237e6a
1 parent 288b8e0
commit c237e6a
Showing 1 changed file with 1 addition and 8 deletions.
diff --git a/plugins/outputs/riemann/riemann.go b/plugins/outputs/riemann/riemann.go
@@ -80,15 +80,8 @@ func (r *Riemann) Write(metrics []telegraf.Metric) error {
 	var senderr = r.client.SendMulti(events)
 	if senderr != nil {
 		r.Close() // always retuns nil
-		connerr := r.Connect()
-		if connerr != nil {
-			return fmt.Errorf("FAILED to (re)connect to Riemann. Error: %s\n", connerr)
-		}
-		senderr = r.client.SendMulti(events)
-		if senderr != nil {
-			return fmt.Errorf("FAILED to send riemann message (will try to reconnect). Error: %s\n",
+		return fmt.Errorf("FAILED to send riemann message (will try to reconnect). Error: %s\n",
 				senderr)
-		}
 	}
 
 	return nil