From 8c8d681093b7ca345f04d4388bd26fe25cc19cb1 Mon Sep 17 00:00:00 2001 From: origin Date: Sat, 28 Jan 2023 16:25:30 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=B6=88=E6=81=AF=E9=98=9F?= =?UTF-8?q?=E5=88=97-=E5=BD=93=E6=B2=A1=E6=9C=89=E6=96=B0=E6=B6=88?= =?UTF-8?q?=E6=81=AF=E6=97=B6=E5=8A=A0=E5=A4=A7=E5=BB=B6=E8=BF=9F=E6=97=B6?= =?UTF-8?q?=E9=97=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sysservice/messagequeueservice/CustomerSubscriber.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sysservice/messagequeueservice/CustomerSubscriber.go b/sysservice/messagequeueservice/CustomerSubscriber.go index 4a45aa1..43746c3 100644 --- a/sysservice/messagequeueservice/CustomerSubscriber.go +++ b/sysservice/messagequeueservice/CustomerSubscriber.go @@ -190,7 +190,7 @@ func (cs *CustomerSubscriber) publishToCustomer(topicData []TopicData) bool { if len(topicData) == 0 { //没有任何数据待一秒吧 - time.Sleep(time.Millisecond * 100) + time.Sleep(time.Second * 1) return true }