From e58891be11f7f15030608a4de6f46f6f1804ed07 Mon Sep 17 00:00:00 2001
From: Sven Rebhan <36194019+srebhan@users.noreply.github.com>
Date: Thu, 9 Mar 2023 15:20:53 +0100
Subject: [PATCH] fix(inputs.amqp_consumer): Fix panic on Stop() if not
 connected successfully (#12817)

---
 plugins/inputs/amqp_consumer/amqp_consumer.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/plugins/inputs/amqp_consumer/amqp_consumer.go b/plugins/inputs/amqp_consumer/amqp_consumer.go
index af0678b8a..5018497a3 100644
--- a/plugins/inputs/amqp_consumer/amqp_consumer.go
+++ b/plugins/inputs/amqp_consumer/amqp_consumer.go
@@ -439,6 +439,10 @@ func (a *AMQPConsumer) onDelivery(track telegraf.DeliveryInfo) bool {
 }
 
 func (a *AMQPConsumer) Stop() {
+	// We did not connect successfully so there is nothing to do here.
+	if a.conn == nil || a.conn.IsClosed() {
+		return
+	}
 	a.cancel()
 	a.wg.Wait()
 	err := a.conn.Close()