replace dep with fork (#184)

Author: subomi

cmd/main.go

@@ -14,10 +14,10 @@ import (
 	"github.com/google/uuid"
 	"go.mongodb.org/mongo-driver/bson/primitive"
 
+	"github.com/Subomi/taskq/v3"
 	"github.com/frain-dev/convoy/util"
 	"github.com/go-redis/redis/v8"
 	log "github.com/sirupsen/logrus"
-	"github.com/vmihailenco/taskq/v3"
 	prefixed "github.com/x-cray/logrus-prefixed-formatter"
 
 	"github.com/frain-dev/convoy"

go.mod

@@ -3,6 +3,7 @@ module github.com/frain-dev/convoy
 go 1.16
 
 require (
+	github.com/Subomi/taskq/v3 v3.2.7-alpha
 	github.com/dgrijalva/jwt-go v3.2.0+incompatible
 	github.com/felixge/httpsnoop v1.0.2
 	github.com/getkin/kin-openapi v0.78.0
@@ -26,7 +27,6 @@ require (
 	github.com/spf13/cobra v1.1.3
 	github.com/stretchr/testify v1.7.0
 	github.com/swaggo/swag v1.7.3
-	github.com/vmihailenco/taskq/v3 v3.2.6
 	github.com/x-cray/logrus-prefixed-formatter v0.5.2
 	github.com/youmark/pkcs8 v0.0.0-20201027041543-1326539a0a0a // indirect
 	go.mongodb.org/mongo-driver v1.7.1

go.sum

@@ -25,6 +25,8 @@ github.com/PuerkitoBio/purell v1.1.1/go.mod h1:c11w/QuzBsJSee3cPx9rAFu61PvFxuPbt
 github.com/PuerkitoBio/urlesc v0.0.0-20170810143723-de5bf2ad4578 h1:d+Bc7a5rLufV/sSk/8dngufqelfh6jnri85riMAaF/M=
 github.com/PuerkitoBio/urlesc v0.0.0-20170810143723-de5bf2ad4578/go.mod h1:uGdkoq3SwY9Y+13GIhn11/XLaGBb4BfwItxLd5jeuXE=
 github.com/Shopify/goreferrer v0.0.0-20181106222321-ec9c9a553398/go.mod h1:a1uqRtAwp2Xwc6WNPJEufxJ7fx3npB4UV/JOLmbu5I0=
+github.com/Subomi/taskq/v3 v3.2.7-alpha h1:rD9OERsbQFBfKU5AayvUdtCVeRmxt5NwhNnmju4KEkc=
+github.com/Subomi/taskq/v3 v3.2.7-alpha/go.mod h1:ulD5nIMANNrb8CB/phkd4GcOQ/uU0yuTFKita7BAKbk=
 github.com/ajg/form v1.5.1/go.mod h1:uL1WgH+h2mgNtvBq0339dVnzXdBETtL2LeUXaIv25UY=
 github.com/alecthomas/template v0.0.0-20160405071501-a0175ee3bccc/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
 github.com/alecthomas/units v0.0.0-20151022065526-2efee857e7cf/go.mod h1:ybxpYRFXyAe+OPACYpWeL0wqObRcbAqCMya13uyzqw0=
@@ -449,8 +451,6 @@ github.com/vmihailenco/msgpack/v5 v5.3.4 h1:qMKAwOV+meBw2Y8k9cVwAy7qErtYCwBzZ2el
 github.com/vmihailenco/msgpack/v5 v5.3.4/go.mod h1:7xyJ9e+0+9SaZT0Wt1RGleJXzli6Q/V5KbhBonMG9jc=
 github.com/vmihailenco/tagparser/v2 v2.0.0 h1:y09buUbR+b5aycVFQs/g70pqKVZNBmxwAhO7/IwNM9g=
 github.com/vmihailenco/tagparser/v2 v2.0.0/go.mod h1:Wri+At7QHww0WTrCBeu4J6bNtoV6mEfg5OIWRZA9qds=
-github.com/vmihailenco/taskq/v3 v3.2.6 h1:kzBdNU2EqSoI9kj9e1s6lwwcryrkfTe1QKcskbGGgI4=
-github.com/vmihailenco/taskq/v3 v3.2.6/go.mod h1:sn+Z2Z5MSs1Ar5Z/hNVp2TMeFOpuWlIJRD1dfjB7Rh8=
 github.com/x-cray/logrus-prefixed-formatter v0.5.2 h1:00txxvfBM9muc0jiLIEAkAcIMJzfthRT6usrui8uGmg=
 github.com/x-cray/logrus-prefixed-formatter v0.5.2/go.mod h1:2duySbKsL6M18s5GU7VPsoEPHyzalCE06qoARUCeBBE=
 github.com/xdg-go/pbkdf2 v1.0.0 h1:Su7DPu48wXMwC3bs7MCNG+z4FhcyEuz5dlvchbq0B0c=

queue/redis/client.go

@@ -5,13 +5,13 @@ import (
 	"errors"
 	"time"
 
+	"github.com/Subomi/taskq/v3"
+	"github.com/Subomi/taskq/v3/redisq"
 	"github.com/frain-dev/convoy"
 	"github.com/frain-dev/convoy/config"
 	"github.com/frain-dev/convoy/queue"
 	"github.com/frain-dev/convoy/util"
 	"github.com/go-redis/redis/v8"
-	"github.com/vmihailenco/taskq/v3"
-	"github.com/vmihailenco/taskq/v3/redisq"
 )
 
 type RedisQueue struct {

worker/cleaner.go

@@ -1,10 +1,10 @@
 package worker
 
 import (
+	"github.com/Subomi/taskq/v3"
 	"github.com/frain-dev/convoy/queue"
 	convoy_redis "github.com/frain-dev/convoy/queue/redis"
 	log "github.com/sirupsen/logrus"
-	"github.com/vmihailenco/taskq/v3"
 )
 
 type Cleaner struct {

worker/producer.go

@@ -3,10 +3,10 @@ package worker
 import (
 	"context"
 
+	"github.com/Subomi/taskq/v3"
 	"github.com/frain-dev/convoy/queue"
 	convoy_redis "github.com/frain-dev/convoy/queue/redis"
 	log "github.com/sirupsen/logrus"
-	"github.com/vmihailenco/taskq/v3"
 )
 
 type Producer struct {

worker/task/task.go

@@ -1,9 +1,9 @@
 package task
 
 import (
+	"github.com/Subomi/taskq/v3"
 	"github.com/frain-dev/convoy"
 	"github.com/frain-dev/convoy/config"
-	"github.com/vmihailenco/taskq/v3"
 )
 
 func CreateTask(name convoy.TaskName, cfg config.Configuration, handler interface{}) *taskq.Task {