修改:延时时间数值类型为long

This commit is contained in:
lxy
2021-05-22 16:19:43 +08:00
parent fc1f91af04
commit f7ef96d0f6
2 changed files with 4 additions and 6 deletions

View File

@@ -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]