chore(redis): add max length in redis xadd

fix #16

Co-Author: @sankethkini

Signed-off-by: Bo-Yi.Wu <[email protected]>

Author: appleboy

options.go

@@ -21,6 +21,7 @@ type options struct {
 	cluster          bool
 	group            string
 	consumer         string
+	maxLength        int64
 }
 
 // WithAddr setup the addr of redis
@@ -30,6 +31,13 @@ func WithAddr(addr string) Option {
 	}
 }
 
+// WithMaxLength setup the max length for publish messages
+func WithMaxLength(m int64) Option {
+	return func(w *options) {
+		w.maxLength = m
+	}
+}
+
 // WithPassword redis password
 func WithDB(db int) Option {
 	return func(w *options) {

redis.go

@@ -208,7 +208,7 @@ func (w *Worker) queue(data interface{}) error {
 	// Publish a message.
 	err := w.rdb.XAdd(ctx, &redis.XAddArgs{
 		Stream: w.opts.streamName,
-		MaxLen: 0,
+		MaxLen: w.opts.maxLength,
 		Values: data,
 	}).Err()