diff --git a/internal/worker/notifications.go b/internal/worker/notifications.go index 47152f9..204bace 100644 --- a/internal/worker/notifications.go +++ b/internal/worker/notifications.go @@ -160,10 +160,8 @@ func (nc *notificationsConsumer) Consume(delivery rmq.Delivery) { return } - newAccount := account.CheckCount == 0 - previousNextCheck := account.NextNotificationCheckAt - account.CheckCount++ + newAccount := account.CheckCount == 1 defer func(acc *domain.Account) { if err = nc.accountRepo.Update(nc, acc); err != nil {