diff --git a/internal/worker/notifications.go b/internal/worker/notifications.go index 08ed73a..b3617ba 100644 --- a/internal/worker/notifications.go +++ b/internal/worker/notifications.go @@ -248,7 +248,7 @@ func (nc *notificationsConsumer) Consume(delivery rmq.Delivery) { nc.logger.WithFields(logrus.Fields{ "accountID": id, }).Debug("fetching message inbox") - msgs, err := rac.MessageUnread(account.LastMessageID) + msgs, err := rac.MessageInbox(account.LastMessageID) if err != nil { nc.logger.WithFields(logrus.Fields{