From 55ef98d1bd56b948b068ac1bb276bec5f9197e03 Mon Sep 17 00:00:00 2001
From: lxy <237809796@qq.com>
Date: Wed, 17 Nov 2021 07:55:05 +0000
Subject: [PATCH] =?UTF-8?q?=E9=8F=82=E6=9D=BF=EE=96=83=E9=94=9B=E6=AD=9Eel?=
 =?UTF-8?q?ay=E9=8A=86=E4=B9=BCimer=20=E9=8D=99=E6=88=A6=E2=82=AC=E4=BD=B9?=
 =?UTF-8?q?=E6=A3=A9=E8=B9=87=3F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

git-svn-id: svn://47.119.165.148/zhub@143 e63fbceb-bcc3-4977-ac22-735b83d8d0f4
---
 zsub/ztimer.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/zsub/ztimer.go b/zsub/ztimer.go
index 43f3ee9..cd8bab1 100644
--- a/zsub/ztimer.go
+++ b/zsub/ztimer.go
@@ -53,6 +53,7 @@ func (s *ZSub) timer(rcmd []string, c *ZConn) {
 
 		var timerFun = func() {
 			for _, conn := range timer.conns {
+				log.Println("timer send:", rcmd[1], rcmd[2])
 				err := conn.send("timer", timer.topic)
 				if timer.single && err == nil {
 					break
@@ -242,6 +243,7 @@ func (s *ZSub) delay(rcmd []string, c *ZConn) {
 		go func() {
 			select {
 			case <-delay.timer.C:
+				log.Println("delay send:", rcmd[1], rcmd[2])
 				zsub.Publish(rcmd[1], rcmd[2])
 				funChan <- func() {
 					delete(s.delays, rcmd[1]+"-"+rcmd[2])