Don't attempt to close Sender on error

Resolves: rhbz#2179924
infrawatch · Jun 8, 2023 · 0c90918 · 0c90918
1 parent 00d2af2
commit 0c90918
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/connector/amqp10/amqp10.go b/connector/amqp10/amqp10.go
@@ -542,11 +542,11 @@ func (conn *AMQP10Connector) Start(outchan chan interface{}, inchan chan interfa
 					} else {
 						if s, err := conn.CreateSender(message.Address); err != nil {
 							conn.logger.Metadata(logging.Metadata{
-								"cause":  "creating sender failed",
-								"reason": err,
+								"cause":   "creating sender failed",
+								"reason":  err,
+								"address": message.Address,
 							})
 							conn.logger.Warn("Skipping processing message")
-							(*s).Close(nil)
 
 							lfLock.Lock()
 							linkFail += 1
@@ -562,8 +562,9 @@ func (conn *AMQP10Connector) Start(outchan chan interface{}, inchan chan interfa
 					if err := (*sender).Error(); err != nil {
 						// verify sender connection
 						conn.logger.Metadata(logging.Metadata{
-							"cause":  "sender disconnected",
-							"reason": err,
+							"cause":   "sender disconnected",
+							"reason":  err,
+							"address": message.Address,
 						})
 						conn.logger.Warn("Skipping processing message")