fix(outputs/amqp): Close the last connection when writing error to avoid connection leaks (#10360)

stitchcula · web-flow · commit 0b96d40b606d · 2022-01-06T16:04:46.000-06:00
diff --git a/plugins/outputs/amqp/amqp.go b/plugins/outputs/amqp/amqp.go
@@ -260,6 +260,9 @@ func (q *AMQP) Write(metrics []telegraf.Metric) error {
 					return err
 				}
 			} else {
+				if err := q.client.Close(); err != nil {
+					q.Log.Errorf("Closing connection failed: %v", err)
+				}
 				q.client = nil
 				return err
 			}

Original file line number	Diff line number	Diff line change
`@@ -260,6 +260,9 @@ func (q *AMQP) Write(metrics []telegraf.Metric) error {`
`260`	`260`	`return err`
`261`	`261`	`}`
`262`	`262`	`} else {`
	`263`	`+ if err := q.client.Close(); err != nil {`
	`264`	`+ q.Log.Errorf("Closing connection failed: %v", err)`
	`265`	`+ }`
`263`	`266`	`q.client = nil`
`264`	`267`	`return err`
`265`	`268`	`}`