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 4
4
5
5
require (
6
6
github.com/golang-queue/nats v0.0.2-0.20210822122542-200fdcf19ebf
7
- github.com/golang-queue/queue v0.0.13-0.20220403053548-d431277d570f
7
+ github.com/golang-queue/queue v0.0.13-0.20220423025512-c4a8df54c917
8
8
)
9
9
10
10
require (
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.20220423025512-c4a8df54c917 h1:+khkGHxQPsad/mfmgizoTc3Jh5UVdCp1OfUkDfW+uDQ =
3
+ github.com/golang-queue/queue v0.0.13-0.20220423025512-c4a8df54c917 /go.mod h1:g1yxxDl8JMo4gUfxt11fjjU3SXU1ah61EvwshmDoSIs =
4
+ github.com/golang/mock v1.6.0 h1:ErTB+efbowRARo13NNdxyJji2egdxLGQhRaY+DUumQc =
4
5
github.com/golang/protobuf v1.5.2 h1:ROPKBNFfQgOUMifHyP+KYbvpjbdoFNs+aK7DXlji0Tw =
5
6
github.com/klauspost/compress v1.15.1 h1:y9FcTHGyrebwfP0ZZqFiaxTaiDnUrGkJkI+f583BL1A =
6
7
github.com/klauspost/compress v1.15.1 /go.mod h1:/3/Vjq9QcHkK5uEr5lBEmyoZ1iFhe47etQ6QUkpK6sk =
Original file line number Diff line number Diff line change 9
9
10
10
"github.com/golang-queue/nats"
11
11
"github.com/golang-queue/queue"
12
+ "github.com/golang-queue/queue/core"
12
13
)
13
14
14
15
type job struct {
@@ -32,7 +33,7 @@ func main() {
32
33
nats .WithAddr ("127.0.0.1:4222" ),
33
34
nats .WithSubj ("example" ),
34
35
nats .WithQueue ("foobar" ),
35
- nats .WithRunFunc (func (ctx context.Context , m queue .QueuedMessage ) error {
36
+ nats .WithRunFunc (func (ctx context.Context , m core .QueuedMessage ) error {
36
37
var v * job
37
38
if err := json .Unmarshal (m .Bytes (), & v ); err != nil {
38
39
return err
You can’t perform that action at this time.
0 commit comments