File tree Expand file tree Collapse file tree 3 files changed +6
-4
lines changed Expand file tree Collapse file tree 3 files changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -2,7 +2,7 @@ module example
2
2
3
3
go 1.18
4
4
5
- require github.com/golang-queue/queue v0.0.13-0.20220403053548-d431277d570f
5
+ require github.com/golang-queue/queue v0.0.13-0.20220408035349-ed24fa14aa00
6
6
7
7
require (
8
8
github.com/golang-queue/nsq v0.0.0-00010101000000-000000000000
Original file line number Diff line number Diff line change 1
1
github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8 =
2
- github.com/golang-queue/queue v0.0.13-0.20220403053548-d431277d570f h1:Wioq3g97ssizNPQsPwdL61DIjePabPaq+XYo7z2t2Oc =
3
- github.com/golang-queue/queue v0.0.13-0.20220403053548-d431277d570f /go.mod h1:KD9age1s6nk8Evz3tfKHsk8k4LwA0htxQ7MS7rJPJzA =
2
+ github.com/golang-queue/queue v0.0.13-0.20220408035349-ed24fa14aa00 h1:EFiINOvAuGgxiE3MNu7PKY0O2Pvvc7r6YApdqAnhWnQ =
3
+ github.com/golang-queue/queue v0.0.13-0.20220408035349-ed24fa14aa00 /go.mod h1:g1yxxDl8JMo4gUfxt11fjjU3SXU1ah61EvwshmDoSIs =
4
+ github.com/golang/mock v1.6.0 h1:ErTB+efbowRARo13NNdxyJji2egdxLGQhRaY+DUumQc =
4
5
github.com/golang/snappy v0.0.1 h1:Qgr9rKW7uDUkrbSmQeiDsGa8SjGyCOGtuasMWwvp2P4 =
5
6
github.com/golang/snappy v0.0.1 /go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q =
6
7
github.com/nsqio/go-nsq v1.1.0 h1:PQg+xxiUjA7V+TLdXw7nVrJ5Jbl3sN86EhGCQj4+FYE =
Original file line number Diff line number Diff line change 9
9
10
10
"github.com/golang-queue/nsq"
11
11
"github.com/golang-queue/queue"
12
+ "github.com/golang-queue/queue/core"
12
13
)
13
14
14
15
type job struct {
@@ -34,7 +35,7 @@ func main() {
34
35
nsq .WithChannel ("foobar" ),
35
36
// concurrent job number
36
37
nsq .WithMaxInFlight (10 ),
37
- nsq .WithRunFunc (func (ctx context.Context , m queue .QueuedMessage ) error {
38
+ nsq .WithRunFunc (func (ctx context.Context , m core .QueuedMessage ) error {
38
39
var v * job
39
40
if err := json .Unmarshal (m .Bytes (), & v ); err != nil {
40
41
return err
You can’t perform that action at this time.
0 commit comments