From 20dbdefe128cdbb6a2c212c2302886b03f23a128 Mon Sep 17 00:00:00 2001
From: Michal Kuratczyk <michal.kuratczyk@broadcom.com>
Date: Thu, 28 Nov 2024 12:14:26 +0100
Subject: [PATCH] Close AMQP publisher session explicitly

---
 pkg/amqp10_client/publisher.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/pkg/amqp10_client/publisher.go b/pkg/amqp10_client/publisher.go
index 1dad4e9..dd4412c 100644
--- a/pkg/amqp10_client/publisher.go
+++ b/pkg/amqp10_client/publisher.go
@@ -265,6 +265,9 @@ func (p *Amqp10Publisher) Send() error {
 
 func (p *Amqp10Publisher) Stop(reason string) {
 	log.Debug("closing connection", "id", p.Id, "reason", reason)
+	if p.Session != nil {
+		_ = p.Session.Close(context.Background())
+	}
 	if p.Connection != nil {
 		_ = p.Connection.Close()
 	}