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()
 	}