diff --git a/cmd/api/server.go b/cmd/api/server.go
index 2c250efb..693858e1 100644
--- a/cmd/api/server.go
+++ b/cmd/api/server.go
@@ -88,6 +88,9 @@ func setup() {
 			log.Fatalf("queue setup error, %s\n", err.Error())
 		}
 		sdk.Runtime.SetQueueAdapter(queueAdapter)
+		defer func() {
+			go queueAdapter.Run()
+		}()
 	}
 
 	//7. 设置分布式锁
@@ -192,4 +195,4 @@ var Router runtime.Router
 func tip() {
 	usageStr := `欢迎使用 ` + pkg.Green(`go-admin `+global.Version) + ` 可以使用 ` + pkg.Red(`-h`) + ` 查看命令`
 	fmt.Printf("%s \n\n", usageStr)
-}
\ No newline at end of file
+}