You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by hu...@apache.org on 2022/03/29 04:31:40 UTC
[rocketmq-mqtt] 12/43: for fix unit test
This is an automated email from the ASF dual-hosted git repository.
huzongtang pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
commit b53fd4d1c2e60afa1c88f4e655571854929c97e8
Author: tianliuliu <64...@qq.com>
AuthorDate: Wed Mar 9 17:47:37 2022 +0800
for fix unit test
---
.../org/apache/rocketmq/mqtt/cs/test/TestDefaultChannelManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/mqtt-cs/src/test/java/org/apache/rocketmq/mqtt/cs/test/TestDefaultChannelManager.java b/mqtt-cs/src/test/java/org/apache/rocketmq/mqtt/cs/test/TestDefaultChannelManager.java
index bb3acfb..06dfd51 100644
--- a/mqtt-cs/src/test/java/org/apache/rocketmq/mqtt/cs/test/TestDefaultChannelManager.java
+++ b/mqtt-cs/src/test/java/org/apache/rocketmq/mqtt/cs/test/TestDefaultChannelManager.java
@@ -46,7 +46,7 @@ public class TestDefaultChannelManager {
FieldUtils.writeDeclaredField(defaultChannelManager, "sessionLoop", sessionLoop, true);
FieldUtils.writeDeclaredField(defaultChannelManager, "connectConf", mock(ConnectConf.class), true);
FieldUtils.writeDeclaredField(defaultChannelManager, "retryDriver", mock(RetryDriver.class), true);
- FieldUtils.writeStaticField(DefaultChannelManager.class, "MinBlankChannelSeconds", 1, true);
+ FieldUtils.writeStaticField(DefaultChannelManager.class, "minBlankChannelSeconds", 1, true);
defaultChannelManager.init();
NioSocketChannel channel = spy(new NioSocketChannel());
when(channel.isActive()).thenReturn(false);