Merge pull request #91 from wework/fix-conn

closing rows when querying transactional outbox fails

Author: Guy Baron

gbus/tx/mysql/txoutbox.go

@@ -241,7 +241,10 @@ func (outbox *TxOutbox) sendMessages(recordSelector func(tx *sql.Tx) (*sql.Rows,
 
 	if selectErr != nil {
 		outbox.log().WithError(selectErr).Error("failed fetching messages from outbox")
-
+		err := rows.Close()
+		if err != nil {
+			outbox.log().WithError(err).Error("could not close Rows")
+		}
 		return selectErr
 	}