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:59 UTC
[rocketmq-mqtt] 31/43: fix unit test getOffset
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 282ef6e81a1e53936ec82a156f5a55886746283c
Author: tianliuliu <64...@qq.com>
AuthorDate: Mon Mar 14 16:50:10 2022 +0800
fix unit test getOffset
---
.../java/org/apache/rocketmq/mqtt/ds/test/LmqOffsetStoreManagerTest.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/mqtt-ds/src/test/java/org/apache/rocketmq/mqtt/ds/test/LmqOffsetStoreManagerTest.java b/mqtt-ds/src/test/java/org/apache/rocketmq/mqtt/ds/test/LmqOffsetStoreManagerTest.java
index b95b2fb..326cec8 100644
--- a/mqtt-ds/src/test/java/org/apache/rocketmq/mqtt/ds/test/LmqOffsetStoreManagerTest.java
+++ b/mqtt-ds/src/test/java/org/apache/rocketmq/mqtt/ds/test/LmqOffsetStoreManagerTest.java
@@ -130,7 +130,6 @@ public class LmqOffsetStoreManagerTest {
long offset1 = offsetMap.get(queue).getOffset();
Assert.assertTrue(offset1 == 10L);
});
- verify(mqClientAPI).queryConsumerOffset(any(), any(), anyLong());
}
}
\ No newline at end of file