diff --git a/gbus/tx/mysql/txoutbox.go b/gbus/tx/mysql/txoutbox.go
index 0a5fa7e..2c49610 100644
--- a/gbus/tx/mysql/txoutbox.go
+++ b/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
 	}