From 0b96d40b606d2496f6e759a281be9aa81e02e7e3 Mon Sep 17 00:00:00 2001
From: stitch cula <stitchgl@outlook.com>
Date: Fri, 7 Jan 2022 06:04:46 +0800
Subject: [PATCH] fix(outputs/amqp): Close the last connection when writing
 error to avoid connection leaks (#10360)

---
 plugins/outputs/amqp/amqp.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/plugins/outputs/amqp/amqp.go b/plugins/outputs/amqp/amqp.go
index 5224928f7..b7029ea77 100644
--- 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
 			}