File tree 5 files changed +7
-22
lines changed
5 files changed +7
-22
lines changed Original file line number Diff line number Diff line change @@ -10,8 +10,6 @@ require (
10
10
require (
11
11
github.com/jpillora/backoff v1.0.0 // indirect
12
12
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
15
13
)
16
14
17
15
replace 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=
16
16
github.com/rs/zerolog v1.26.1 /go.mod h1:/wSSJWX7lVrsOwlbyTRSOJvqRlc+WjWlfes+CiJ+tmc =
17
17
github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA =
18
18
github.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 =
23
19
github.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 =
26
22
go.uber.org/mock v0.5.0 h1:KAMbZvZPyBPWgD14IrIQ38QCyjwpvVVV6K/bHl1IwQU =
27
23
go.uber.org/mock v0.5.0 /go.mod h1:ge71pBPLYDk7QIi1LupWxdAykm7KIEFchiOqd6z7qMM =
28
24
golang.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 (
12
12
github.com/mattn/go-colorable v0.1.14 // indirect
13
13
github.com/mattn/go-isatty v0.0.20 // indirect
14
14
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
17
15
golang.org/x/sys v0.29.0 // indirect
18
16
)
19
17
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=
23
23
github.com/rs/zerolog v1.33.0 /go.mod h1:/7mN4D5sKwJLZQ2b/znpjC3/GQWY/xaDXUM0kKWRHss =
24
24
github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA =
25
25
github.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 =
32
28
go.uber.org/mock v0.5.0 h1:KAMbZvZPyBPWgD14IrIQ38QCyjwpvVVV6K/bHl1IwQU =
33
29
go.uber.org/mock v0.5.0 /go.mod h1:ge71pBPLYDk7QIi1LupWxdAykm7KIEFchiOqd6z7qMM =
34
30
golang.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() {
31
31
32
32
// initial queue pool
33
33
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
39
37
}
40
-
41
38
rets <- "Hi, " + v .Name + ", " + v .Message
42
39
return nil
43
40
}), queue .WithLogger (zerolog .New ()))
You can’t perform that action at this time.
0 commit comments