lxy/zhub
1
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

修改：支持 timer 批量一次订阅

Browse Source 
git-svn-id: svn://47.119.165.148/zhub@117 e63fbceb-bcc3-4977-ac22-735b83d8d0f4
This commit is contained in:
lxy
2021-03-05 09:35:36 +00:00
parent bb3802f0aa
commit 716b36e864
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
zsub/msg-consumer.go
View File

@@ -38,7 +38,7 @@ func msgAccept(v Message) {
return false return false
} }
arr := []string{"subscribe", "unsubscribe", "delay", "groupid"} arr := []string{"subscribe", "timer", "unsubscribe", "delay", "groupid"}
if startWithAny(rcmd[0], arr...) { if startWithAny(rcmd[0], arr...) {
rcmd = strings.Split(rcmd[0], " ") rcmd = strings.Split(rcmd[0], " ")
} else { } else {
@@ -85,7 +85,9 @@ func msgAccept(v Message) {
case "delay": case "delay":
zsub.delay(rcmd, c) zsub.delay(rcmd, c)
case "timer": case "timer":
zsub.timer(rcmd, c) for _, name := range rcmd[1:] {
zsub.timer([]string{"timer", name}, c)
}
case "cmd": case "cmd":
if len(rcmd) == 1 { if len(rcmd) == 1 {
return return