less verbose logging

This commit is contained in:
James Mills 2022-04-03 20:25:06 +10:00
parent 1f8b369266
commit b4e7582a6d
No known key found for this signature in database
GPG Key ID: AC4C014F1440EBD6

View File

@ -588,7 +588,7 @@ func (mb *MessageBus) Subscribe(id, topic string, opts ...SubscribeOption) chan
log.Debugf("subscriber wants to start from %d", o.Index)
q.ForEach(func(item interface{}) error {
if msg, ok := item.(Message); ok && msg.ID >= o.Index {
log.Debugf("found #%v", msg)
log.Debugf("found msg #%d", msg.ID)
ch <- msg
n++
}