remove debug log messages
This commit is contained in:
@@ -110,10 +110,8 @@ func (s Subscriber) listen(messages <-chan *message.Message, wg *sync.WaitGroup)
|
||||
if err := s.processEvent(msg); err != nil {
|
||||
s.logger.Warn("Failed to process msg: ", err)
|
||||
|
||||
s.logger.Infow("message nacked", "event.id", msg.UUID)
|
||||
msg.Nack()
|
||||
} else {
|
||||
s.logger.Infow("message acked", "event.id", msg.UUID)
|
||||
msg.Ack()
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user