You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by di...@apache.org on 2022/04/18 04:56:27 UTC
[rocketmq-mqtt] branch main updated: fix #75 the unit test error in main (#76)
This is an automated email from the ASF dual-hosted git repository.
dinglei pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
The following commit(s) were added to refs/heads/main by this push:
new 34f499c fix #75 the unit test error in main (#76)
34f499c is described below
commit 34f499c7249ee82d6c89812aa25ea46dfa1a3224
Author: tianliuliu <64...@qq.com>
AuthorDate: Mon Apr 18 12:56:23 2022 +0800
fix #75 the unit test error in main (#76)
---
.../mqtt/cs/test/protocol/mqtt/handler/TestMqttConnectHandler.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/mqtt-cs/src/test/java/org/apache/rocketmq/mqtt/cs/test/protocol/mqtt/handler/TestMqttConnectHandler.java b/mqtt-cs/src/test/java/org/apache/rocketmq/mqtt/cs/test/protocol/mqtt/handler/TestMqttConnectHandler.java
index 4ff35ef..4d2907d 100644
--- a/mqtt-cs/src/test/java/org/apache/rocketmq/mqtt/cs/test/protocol/mqtt/handler/TestMqttConnectHandler.java
+++ b/mqtt-cs/src/test/java/org/apache/rocketmq/mqtt/cs/test/protocol/mqtt/handler/TestMqttConnectHandler.java
@@ -108,7 +108,7 @@ public class TestMqttConnectHandler {
// wait scheduler execution
try {
- Thread.sleep(1000);
+ Thread.sleep(1100);
} catch (InterruptedException ignored) {}
verify(sessionLoop).loadSession(any(), any());
@@ -125,7 +125,7 @@ public class TestMqttConnectHandler {
// wait scheduler execution
try {
- Thread.sleep(1000);
+ Thread.sleep(2000);
} catch (InterruptedException ignored) {}
verify(channel).writeAndFlush(any(MqttConnAckMessage.class));