Skip to content

Commit d666f24

Browse files
committed
Remove debug
1 parent 09fa213 commit d666f24

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

‎pkg/bolt/delay_subscriber.go‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -47,10 +47,8 @@ func getMessagesWithDelay(_ context.Context, s *Subscriber, topic string) ([]raw
4747
for k, v := c.First(); k != nil; k, v = c.Next() {
4848
keyTime, err := extractTimestamp(k)
4949
if err != nil {
50-
fmt.Println("DEBUG: skipping key with invalid timestamp:", string(k), err)
5150
continue
5251
}
53-
fmt.Println("DEBUG: processing key with time:", string(k), keyTime, "now:", now)
5452

5553
if keyTime.Before(now) || keyTime.Equal(now) {
5654
messages = append(messages, newRawMessage(k, v))

0 commit comments

Comments
 (0)