From 76d30ffd309f474d241deb3512b61304e8ee3ed4 Mon Sep 17 00:00:00 2001 From: medcl Date: Fri, 21 Jan 2022 22:01:06 +0800 Subject: [PATCH] update main --- main.go | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/main.go b/main.go index 7059a856..783f8221 100644 --- a/main.go +++ b/main.go @@ -9,12 +9,12 @@ import ( "infini.sh/framework/core/module" "infini.sh/framework/core/orm" pipe "infini.sh/framework/core/pipeline" + queue2 "infini.sh/framework/modules/disk_queue" elastic2 "infini.sh/framework/modules/elastic" "infini.sh/framework/modules/filter" "infini.sh/framework/modules/metrics" "infini.sh/framework/modules/pipeline" - "infini.sh/framework/modules/queue" - queue2 "infini.sh/framework/modules/queue/disk_queue" + "infini.sh/framework/modules/redis" "infini.sh/framework/modules/stats" "infini.sh/framework/modules/task" "infini.sh/framework/modules/ui" @@ -51,8 +51,7 @@ func main() { module.RegisterSystemModule(&filter.FilterModule{}) module.RegisterSystemModule(&stats.SimpleStatsModule{}) module.RegisterSystemModule(&queue2.DiskQueue{}) - module.RegisterSystemModule(&queue.RedisModule{}) - module.RegisterSystemModule(&queue.QueueModule{}) + module.RegisterSystemModule(&redis.RedisModule{}) module.RegisterSystemModule(&ui.UIModule{}) module.RegisterSystemModule(&pipeline.PipeModule{}) module.RegisterSystemModule(&task.TaskModule{})