fix: improve Redis error handling and logging in fetchTask (#36)

- Add handling for Redis 'no message' errors in fetchTask
- Log a specific info message when no messages are available, then continue retrying

fix #31

Signed-off-by: appleboy <appleboy.tw@gmail.com>

Author: appleboy

redis.go

@@ -3,6 +3,7 @@ package redisdb
 import (
 	"context"
 	"encoding/json"
+	"errors"
 	"strings"
 	"sync"
 	"sync/atomic"
@@ -110,6 +111,10 @@ func (w *Worker) fetchTask() {
 			Block: w.opts.blockTime,
 		}).Result()
 		if err != nil {
+			if errors.Is(err, redis.Nil) {
+				w.opts.logger.Infof("no messages available in Redis stream [%s]", w.opts.streamName)
+				continue
+			}
 			w.opts.logger.Errorf("error while reading from redis %v", err)
 			continue
 		}