diff --git a/broker/broker.go b/broker/broker.go index 79b01b3..87e2a24 100644 --- a/broker/broker.go +++ b/broker/broker.go @@ -14,7 +14,7 @@ import ( "github.com/oarkflow/xid" "github.com/oarkflow/xsync" - "github.com/oarkflow/golong/utils" + "github.com/oarkflow/mq/utils" ) type Handler func(context.Context, Task) Result diff --git a/examples/consumer.go b/examples/consumer.go index 0b6fd13..6020e2e 100644 --- a/examples/consumer.go +++ b/examples/consumer.go @@ -4,7 +4,7 @@ import ( "context" "fmt" - "github.com/oarkflow/golong/broker" + "github.com/oarkflow/mq/broker" ) func main() { diff --git a/examples/dag.go b/examples/dag.go index 44e3388..91da165 100644 --- a/examples/dag.go +++ b/examples/dag.go @@ -6,7 +6,7 @@ import ( "fmt" "time" - "github.com/oarkflow/golong/broker" + "github.com/oarkflow/mq/broker" ) func handleNode1(_ context.Context, task broker.Task) broker.Result { diff --git a/examples/server.go b/examples/server.go index fa2703b..e19ede6 100644 --- a/examples/server.go +++ b/examples/server.go @@ -5,7 +5,7 @@ import ( "fmt" "time" - "github.com/oarkflow/golong/broker" + "github.com/oarkflow/mq/broker" ) func main() { diff --git a/go.mod b/go.mod index 8f20417..789f208 100644 --- a/go.mod +++ b/go.mod @@ -1,7 +1,7 @@ -module github.com/oarkflow/golong +module github.com/oarkflow/mq go 1.23 require github.com/oarkflow/xsync v0.0.5 -require github.com/oarkflow/xid v1.2.5 // indirect +require github.com/oarkflow/xid v1.2.5