mirrors/apollo-backend
2
0
Fork 0
mirror of https://github.com/christianselig/apollo-backend synced 2024-11-22 03:37:43 +00:00
Code Issues Projects Releases Packages Wiki Activity

remove dead logic

Browse source
This commit is contained in:
Andre Medeiros 2021-07-15 11:03:52 -04:00
parent 5ebac84014
commit a9a329967a
1 changed files with 0 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
internal/worker/notifications.go
View file

@ -283,13 +283,6 @@ func (nc *notificationsConsumer) Consume(delivery rmq.Delivery) {
"count": len(tt),
}).Debug("fetched messages")
if len(tt) == 0 {
nc.logger.WithFields(logrus.Fields{
"accountID": id,
}).Debug("no new messages, bailing early")
return
}
// Set latest message we alerted on
latestMsg := tt[0]
if err = nc.db.BeginFunc(ctx, func(tx pgx.Tx) error {