diff --git a/cmd/api/server.go b/cmd/api/server.go
index 48b13d67..af3f211b 100644
--- a/cmd/api/server.go
+++ b/cmd/api/server.go
@@ -82,6 +82,9 @@ func setup() {
 			log.Fatalf("queue setup error, %s\n", err.Error())
 		}
 		sdk.Runtime.SetQueueAdapter(queueAdapter)
+		defer func() {
+			go queueAdapter.Run()
+		}()
 	}
 
 	//7. 设置分布式锁