diff --git a/internal/worker/notifications.go b/internal/worker/notifications.go index e46f20c..a259044 100644 --- a/internal/worker/notifications.go +++ b/internal/worker/notifications.go @@ -353,6 +353,8 @@ func (nc *notificationsConsumer) Consume(delivery rmq.Delivery) { } } + nc.statsd.SimpleEvent("Sent notification", account.Username) + nc.logger.WithFields(logrus.Fields{ "accountID": delivery.Payload(), }).Debug("finishing job")