From 0314991f9e24b17181742a615adacd15da138625 Mon Sep 17 00:00:00 2001
From: linwenxiang <991154416@qq.com>
Date: Mon, 31 May 2021 14:39:27 +0800
Subject: [PATCH] =?UTF-8?q?fix=20:bug:=20=E4=BF=AE=E5=A4=8Dqueue=20redis?=
 =?UTF-8?q?=E6=A8=A1=E5=BC=8F=E9=98=BF=E9=87=8C=E4=BA=91=E4=B8=8D=E5=B7=A5?=
 =?UTF-8?q?=E4=BD=9C=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 cmd/api/server.go | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/cmd/api/server.go b/cmd/api/server.go
index 4ae9c0a9..507119d0 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. 设置分布式锁
@@ -200,4 +203,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
+}