From 716b36e864f1a6c09ff43f215bc0dba5b74768e1 Mon Sep 17 00:00:00 2001
From: lxy <237809796@qq.com>
Date: Fri, 5 Mar 2021 09:35:36 +0000
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=EF=BC=9A=E6=94=AF=E6=8C=81?=
 =?UTF-8?q?=20timer=20=E6=89=B9=E9=87=8F=E4=B8=80=E6=AC=A1=E8=AE=A2?=
 =?UTF-8?q?=E9=98=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

git-svn-id: svn://47.119.165.148/zhub@117 e63fbceb-bcc3-4977-ac22-735b83d8d0f4
---
 zsub/msg-consumer.go | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/zsub/msg-consumer.go b/zsub/msg-consumer.go
index 6b03d43..da8fcd2 100644
--- a/zsub/msg-consumer.go
+++ b/zsub/msg-consumer.go
@@ -38,7 +38,7 @@ func msgAccept(v Message) {
 				return false
 			}
 
-			arr := []string{"subscribe", "unsubscribe", "delay", "groupid"}
+			arr := []string{"subscribe", "timer", "unsubscribe", "delay", "groupid"}
 			if startWithAny(rcmd[0], arr...) {
 				rcmd = strings.Split(rcmd[0], " ")
 			} else {
@@ -85,7 +85,9 @@ func msgAccept(v Message) {
 		case "delay":
 			zsub.delay(rcmd, c)
 		case "timer":
-			zsub.timer(rcmd, c)
+			for _, name := range rcmd[1:] {
+				zsub.timer([]string{"timer", name}, c)
+			}
 		case "cmd":
 			if len(rcmd) == 1 {
 				return