Close AMQP publisher session explicitly

rabbitmq · Nov 28, 2024 · 20dbdef · 20dbdef
1 parent 15a3ce4
commit 20dbdef
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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()
 	}