diff --git a/templates/project/pkg/service/queue/river.go.tpl b/templates/project/pkg/service/queue/river.go.tpl index a0e0eda..45fb13f 100644 --- a/templates/project/pkg/service/queue/river.go.tpl +++ b/templates/project/pkg/service/queue/river.go.tpl @@ -3,11 +3,11 @@ package queue import ( "context" - "demo01/app/jobs" - "demo01/pkg/service" - "demo01/providers/app" - "demo01/providers/job" - "demo01/providers/postgres" + "{{.ModuleName}}/app/jobs" + "{{.ModuleName}}/pkg/service" + "{{.ModuleName}}/providers/app" + "{{.ModuleName}}/providers/job" + "{{.ModuleName}}/providers/postgres" "git.ipao.vip/rogeecn/atom" "git.ipao.vip/rogeecn/atom/container" diff --git a/templates/project/providers/job/provider.go.tpl b/templates/project/providers/job/provider.go.tpl index c9a83f6..dac6f74 100644 --- a/templates/project/providers/job/provider.go.tpl +++ b/templates/project/providers/job/provider.go.tpl @@ -4,7 +4,7 @@ import ( "context" "sync" - "demo01/providers/postgres" + "{{.ModuleName}}/providers/postgres" "git.ipao.vip/rogeecn/atom/container" "git.ipao.vip/rogeecn/atom/utils/opt" @@ -71,9 +71,9 @@ func (q *Job) Client() (*river.Client[pgx.Tx], error) { q.client, err = river.NewClient(q.Driver, &river.Config{ Workers: q.Workers, Queues: map[string]river.QueueConfig{ - PriorityHigh: {MaxWorkers: 10}, - PriorityDefault: {MaxWorkers: 10}, - PriorityLow: {MaxWorkers: 10}, + QueueHigh: {MaxWorkers: 10}, + QueueDefault: {MaxWorkers: 10}, + QueueLow: {MaxWorkers: 10}, }, }) if err != nil {