From 0d8ef5ddb15f82c442a18f9e8316a8c1f02edec3 Mon Sep 17 00:00:00 2001
From: Michal Kuratczyk <mkuratczyk@vmware.com>
Date: Tue, 3 Sep 2024 17:39:07 +0200
Subject: [PATCH] STOMP consumer Stop() loggging

---
 pkg/stomp_client/consumer.go | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/pkg/stomp_client/consumer.go b/pkg/stomp_client/consumer.go
index 0aff03f..3b32725 100644
--- a/pkg/stomp_client/consumer.go
+++ b/pkg/stomp_client/consumer.go
@@ -152,13 +152,19 @@ func (c *StompConsumer) Start(ctx context.Context, subscribed chan bool) {
 }
 
 func (c *StompConsumer) Stop(reason string) {
-	log.Debug("closing connection", "id", c.Id, "reason", reason)
 	if c.Subscription != nil {
-		_ = c.Subscription.Unsubscribe()
+		err := c.Subscription.Unsubscribe()
+		if err != nil {
+			log.Info("failed to unsubscribe", "id", c.Id, "error", err.Error())
+		}
 	}
 	if c.Connection != nil {
-		_ = c.Connection.Disconnect()
+		err := c.Connection.Disconnect()
+		if err != nil {
+			log.Info("failed to disconnect", "id", c.Id, "error", err.Error())
+		}
 	}
+	log.Debug("consumer stopped", "id", c.Id)
 }
 
 func buildSubscribeOpts(cfg config.Config) []func(*frame.Frame) error {