diff --git a/postgresql/notifications_store.go b/postgresql/notifications_store.go index 1cd00b7..f020ab5 100644 --- a/postgresql/notifications_store.go +++ b/postgresql/notifications_store.go @@ -60,6 +60,7 @@ func (s *NotificationsStore) GetRegistrations( if err != nil { return nil, err } + defer rows.Close() var result []string for rows.Next() { diff --git a/postgresql/opening_store.go b/postgresql/opening_store.go index 8eea49b..4a93f6c 100644 --- a/postgresql/opening_store.go +++ b/postgresql/opening_store.go @@ -30,6 +30,7 @@ func (s *PostgresOpeningStore) GetFeeParamsSettings(token string) ([]*common.Ope log.Printf("GetFeeParamsSettings(%v) error: %v", token, err) return nil, err } + defer rows.Close() var settings []*common.OpeningFeeParamsSetting for rows.Next() {