diff --git a/service/adapters/sqlite/pubsub.go b/service/adapters/sqlite/pubsub.go index 1435719..efa1adb 100644 --- a/service/adapters/sqlite/pubsub.go +++ b/service/adapters/sqlite/pubsub.go @@ -152,13 +152,9 @@ func (p *PubSub) subscribe(ctx context.Context, topic string, ch chan *ReceivedM noMessagesCounter := 0 for { - p.logger.Debug().Message("reading message") - msg, err := p.readMsg(topic) if err != nil { if errors.Is(err, sql.ErrNoRows) { - p.logger.Debug().Message("no rows") - noMessagesCounter++ backoff := getNoMessagesBackoff(noMessagesCounter)