File tree Expand file tree Collapse file tree 5 files changed +7
-22
lines changed Expand file tree Collapse file tree 5 files changed +7
-22
lines changed Original file line number Diff line number Diff line change @@ -10,8 +10,6 @@ require (
1010require (
1111 github.com/jpillora/backoff v1.0.0 // indirect
1212 github.com/rs/zerolog v1.26.1 // indirect
13- github.com/vmihailenco/msgpack/v5 v5.4.1 // indirect
14- github.com/vmihailenco/tagparser/v2 v2.0.0 // indirect
1513)
1614
1715replace github.com/golang-queue/queue => ../../
Original file line number Diff line number Diff line change @@ -16,13 +16,9 @@ github.com/rs/zerolog v1.26.1 h1:/ihwxqH+4z8UxyI70wM1z9yCvkWcfz/a3mj48k/Zngc=
1616github.com/rs/zerolog v1.26.1 /go.mod h1:/wSSJWX7lVrsOwlbyTRSOJvqRlc+WjWlfes+CiJ+tmc =
1717github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA =
1818github.com/stretchr/testify v1.10.0 /go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY =
19- github.com/vmihailenco/msgpack/v5 v5.4.1 h1:cQriyiUvjTwOHg8QZaPihLWeRAAVoCpE00IUPn0Bjt8 =
20- github.com/vmihailenco/msgpack/v5 v5.4.1 /go.mod h1:GaZTsDaehaPpQVyxrf5mtQlH+pc21PIudVV/E3rRQok =
21- github.com/vmihailenco/tagparser/v2 v2.0.0 h1:y09buUbR+b5aycVFQs/g70pqKVZNBmxwAhO7/IwNM9g =
22- github.com/vmihailenco/tagparser/v2 v2.0.0 /go.mod h1:Wri+At7QHww0WTrCBeu4J6bNtoV6mEfg5OIWRZA9qds =
2319github.com/yuin/goldmark v1.4.0 /go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1Zlc8k =
24- go.uber.org/goleak v1.2.1 h1:NBol2c7O1ZokfZ0LEU9K6Whx/KnwvepVetCUhtKja4A =
25- go.uber.org/goleak v1.2.1 /go.mod h1:qlT2yGI9QafXHhZZLxlSuNsMw3FFLxBr+tBRlmO1xH4 =
20+ go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto =
21+ go.uber.org/goleak v1.3.0 /go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE =
2622go.uber.org/mock v0.5.0 h1:KAMbZvZPyBPWgD14IrIQ38QCyjwpvVVV6K/bHl1IwQU =
2723go.uber.org/mock v0.5.0 /go.mod h1:ge71pBPLYDk7QIi1LupWxdAykm7KIEFchiOqd6z7qMM =
2824golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2 /go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w =
Original file line number Diff line number Diff line change @@ -12,8 +12,6 @@ require (
1212 github.com/mattn/go-colorable v0.1.14 // indirect
1313 github.com/mattn/go-isatty v0.0.20 // indirect
1414 github.com/rs/zerolog v1.33.0 // indirect
15- github.com/vmihailenco/msgpack/v5 v5.4.1 // indirect
16- github.com/vmihailenco/tagparser/v2 v2.0.0 // indirect
1715 golang.org/x/sys v0.29.0 // indirect
1816)
1917
Original file line number Diff line number Diff line change @@ -23,12 +23,8 @@ github.com/rs/zerolog v1.33.0 h1:1cU2KZkvPxNyfgEmhHAz/1A9Bz+llsdYzklWFzgp0r8=
2323github.com/rs/zerolog v1.33.0 /go.mod h1:/7mN4D5sKwJLZQ2b/znpjC3/GQWY/xaDXUM0kKWRHss =
2424github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA =
2525github.com/stretchr/testify v1.10.0 /go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY =
26- github.com/vmihailenco/msgpack/v5 v5.4.1 h1:cQriyiUvjTwOHg8QZaPihLWeRAAVoCpE00IUPn0Bjt8 =
27- github.com/vmihailenco/msgpack/v5 v5.4.1 /go.mod h1:GaZTsDaehaPpQVyxrf5mtQlH+pc21PIudVV/E3rRQok =
28- github.com/vmihailenco/tagparser/v2 v2.0.0 h1:y09buUbR+b5aycVFQs/g70pqKVZNBmxwAhO7/IwNM9g =
29- github.com/vmihailenco/tagparser/v2 v2.0.0 /go.mod h1:Wri+At7QHww0WTrCBeu4J6bNtoV6mEfg5OIWRZA9qds =
30- go.uber.org/goleak v1.2.1 h1:NBol2c7O1ZokfZ0LEU9K6Whx/KnwvepVetCUhtKja4A =
31- go.uber.org/goleak v1.2.1 /go.mod h1:qlT2yGI9QafXHhZZLxlSuNsMw3FFLxBr+tBRlmO1xH4 =
26+ go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto =
27+ go.uber.org/goleak v1.3.0 /go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE =
3228go.uber.org/mock v0.5.0 h1:KAMbZvZPyBPWgD14IrIQ38QCyjwpvVVV6K/bHl1IwQU =
3329go.uber.org/mock v0.5.0 /go.mod h1:ge71pBPLYDk7QIi1LupWxdAykm7KIEFchiOqd6z7qMM =
3430golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab /go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg =
Original file line number Diff line number Diff line change @@ -31,13 +31,10 @@ func main() {
3131
3232 // initial queue pool
3333 q := queue .NewPool (5 , queue .WithFn (func (ctx context.Context , m core.TaskMessage ) error {
34- v , ok := m .(* job )
35- if ! ok {
36- if err := json .Unmarshal (m .Payload (), & v ); err != nil {
37- return err
38- }
34+ var v job
35+ if err := json .Unmarshal (m .Payload (), & v ); err != nil {
36+ return err
3937 }
40-
4138 rets <- "Hi, " + v .Name + ", " + v .Message
4239 return nil
4340 }), queue .WithLogger (zerolog .New ()))
You can’t perform that action at this time.
0 commit comments