chore(channel): default channel size in go-redis package

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

Author: appleboy

go.mod

@@ -4,7 +4,7 @@ go 1.16
 
 require (
 	github.com/go-redis/redis/v8 v8.11.3
-	github.com/golang-queue/queue v0.0.13-0.20220408035349-ed24fa14aa00
+	github.com/golang-queue/queue v0.0.13-0.20220423074840-a2e1b18a04ae
 	github.com/stretchr/testify v1.7.1
 	go.uber.org/goleak v1.1.12
 )

go.sum

@@ -11,8 +11,8 @@ github.com/fsnotify/fsnotify v1.4.9/go.mod h1:znqG4EE+3YCdAaPaxE2ZRY/06pZUdp0tY4
 github.com/go-redis/redis/v8 v8.11.3 h1:GCjoYp8c+yQTJfc0n69iwSiHjvuAdruxl7elnZCxgt8=
 github.com/go-redis/redis/v8 v8.11.3/go.mod h1:xNJ9xDG09FsIPwh3bWdk+0oDWHbtF9rPN0F/oD9XeKc=
 github.com/go-task/slim-sprig v0.0.0-20210107165309-348f09dbbbc0/go.mod h1:fyg7847qk6SyHyPtNmDHnmrv/HOrqktSC+C9fM+CJOE=
-github.com/golang-queue/queue v0.0.13-0.20220408035349-ed24fa14aa00 h1:EFiINOvAuGgxiE3MNu7PKY0O2Pvvc7r6YApdqAnhWnQ=
-github.com/golang-queue/queue v0.0.13-0.20220408035349-ed24fa14aa00/go.mod h1:g1yxxDl8JMo4gUfxt11fjjU3SXU1ah61EvwshmDoSIs=
+github.com/golang-queue/queue v0.0.13-0.20220423074840-a2e1b18a04ae h1:LHyA1IaDD9hNm8S/pGql0yebtbMCC7XTBB7zMRqyU70=
+github.com/golang-queue/queue v0.0.13-0.20220423074840-a2e1b18a04ae/go.mod h1:g1yxxDl8JMo4gUfxt11fjjU3SXU1ah61EvwshmDoSIs=
 github.com/golang/mock v1.6.0 h1:ErTB+efbowRARo13NNdxyJji2egdxLGQhRaY+DUumQc=
 github.com/golang/mock v1.6.0/go.mod h1:p6yTPP+5HYm5mzsMV8JkE6ZKdX+/wYM6Hr+LicevLPs=
 github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=

options.go

@@ -89,7 +89,8 @@ func newOptions(opts ...Option) options {
 	defaultOpts := options{
 		addr:        "127.0.0.1:6379",
 		channelName: "queue",
-		channelSize: 1024,
+		// default channel size in go-redis package
+		channelSize: 100,
 		logger:      queue.NewLogger(),
 		runFunc: func(context.Context, core.QueuedMessage) error {
 			return nil