Skip to content

Commit

Permalink
No debug
Browse files Browse the repository at this point in the history
  • Loading branch information
boreq committed Oct 31, 2023
1 parent 527828c commit 2cb397b
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions service/adapters/sqlite/pubsub.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)

Expand Down

0 comments on commit 2cb397b

Please sign in to comment.