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

log message acknowledgement

Browse source
This commit is contained in:
Andre Medeiros 2022-07-13 13:24:32 -04:00
parent aaf1fbd98a
commit f785d1a3a4
1 changed files with 7 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
internal/worker/notifications.go
View file

@ -137,16 +137,20 @@ func NewNotificationsConsumer(nw *notificationsWorker, tag int) *notificationsCo
func (nc *notificationsConsumer) Consume(delivery rmq.Delivery) { func (nc *notificationsConsumer) Consume(delivery rmq.Delivery) {
id := delivery.Payload() id := delivery.Payload()
defer func(id string) { defer func() {
key := fmt.Sprintf("locks:accounts:%s", id) key := fmt.Sprintf("locks:accounts:%s", id)
if err := nc.redis.Del(nc, key).Err(); err != nil { if err := nc.redis.Del(nc, key).Err(); err != nil {
nc.logger.Error("failed to remove account lock", zap.Error(err), zap.String("key", key)) nc.logger.Error("failed to remove account lock", zap.Error(err), zap.String("key", key))
} }
}(id) }()
nc.logger.Debug("starting job", zap.String("account#reddit_account_id", id)) nc.logger.Debug("starting job", zap.String("account#reddit_account_id", id))
defer func() { _ = delivery.Ack() }() defer func() {
if err := delivery.Ack(); err != nil {
nc.logger.Error("failed to acknowledge message", zap.Error(err), zap.String("account#reddit_account_id", id))
}
}()
now := time.Now() now := time.Now()