From 1f23dbf3cd4f74c0056e038f2cf157b579a676e9 Mon Sep 17 00:00:00 2001
From: lxy <237809796@qq.com>
Date: Sat, 22 May 2021 16:19:43 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=EF=BC=9A=E5=BB=B6=E6=97=B6?=
 =?UTF-8?q?=E6=97=B6=E9=97=B4=E6=95=B0=E5=80=BC=E7=B1=BB=E5=9E=8B=E4=B8=BA?=
 =?UTF-8?q?long?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/com/zdemo/zhub/ZHubClient.java | 4 ++--
 test/com/zdemo/test/AppTest.java   | 6 ++----
 2 files changed, 4 insertions(+), 6 deletions(-)

diff --git a/src/com/zdemo/zhub/ZHubClient.java b/src/com/zdemo/zhub/ZHubClient.java
index 875e209..4aca092 100644
--- a/src/com/zdemo/zhub/ZHubClient.java
+++ b/src/com/zdemo/zhub/ZHubClient.java
@@ -361,8 +361,8 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
     }
 
     // 发送 publish 主题消息，若多次发送的 topic + "-" + value 相同，将会做延时重置
-    public void delay(String topic, Object v, int delay) {
-        send("delay", topic, toStr(v), String.valueOf(delay));
+    public void delay(String topic, Object v, long millis) {
+        send("delay", topic, toStr(v), String.valueOf(millis));
     }
 
     // 表达式支持：d+[d,H,m,s]
diff --git a/test/com/zdemo/test/AppTest.java b/test/com/zdemo/test/AppTest.java
index e141d1c..2b80817 100644
--- a/test/com/zdemo/test/AppTest.java
+++ b/test/com/zdemo/test/AppTest.java
@@ -2,7 +2,6 @@ package com.zdemo.test;
 
 import com.zdemo.Event;
 import com.zdemo.IProducer;
-import com.zdemo.zhub.Lock;
 import org.junit.Test;
 import org.redkale.boot.Application;
 import org.redkale.convert.json.JsonConvert;
@@ -12,7 +11,6 @@ import java.util.List;
 import java.util.Map;
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.TimeUnit;
-import java.util.function.Consumer;
 import java.util.function.Function;
 import java.util.logging.Logger;
 
@@ -47,7 +45,7 @@ public class AppTest {
             //consumer.delay("a", "1", 200);
             consumer.delay("a", "1", "2000");*/
 
-            Consumer<String> con = x -> {
+            /*Consumer<String> con = x -> {
                 logger.info("--->开始申请锁:" + System.currentTimeMillis());
                 Lock lock = consumer.tryLock("a", 20);
                 logger.info("===>成功申请锁:" + System.currentTimeMillis());
@@ -64,7 +62,7 @@ public class AppTest {
 
             new Thread(() -> con.accept("x")).start();
             new Thread(() -> con.accept("y")).start();
-            new Thread(() -> con.accept("z")).start();
+            new Thread(() -> con.accept("z")).start();*/
 
 
             Thread.sleep(60_000 * 60);