You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2021/04/19 10:38:22 UTC
[rocketmq] branch develop updated: [ISSUE #2811] Fix the wrong
topic was consumed in the DefaultMessageStoreTest test program
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 0b6bd18 [ISSUE #2811] Fix the wrong topic was consumed in the DefaultMessageStoreTest test program
new 8eb0472 Merge pull request #2824 from BurningCN/fix_test_consume_wrong_topic
0b6bd18 is described below
commit 0b6bd183bfffb17f8cb112ae6d080e908ebbca1e
Author: BurningCN <10...@qq.com>
AuthorDate: Mon Apr 19 11:37:38 2021 +0800
[ISSUE #2811] Fix the wrong topic was consumed in the DefaultMessageStoreTest test program
---
.../test/java/org/apache/rocketmq/store/DefaultMessageStoreTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreTest.java b/store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreTest.java
index fd13e71..440f914 100644
--- a/store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreTest.java
+++ b/store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreTest.java
@@ -133,7 +133,7 @@ public class DefaultMessageStoreTest {
StoreTestUtil.waitCommitLogReput((DefaultMessageStore) messageStore);
for (long i = 0; i < totalMsgs; i++) {
- GetMessageResult result = messageStore.getMessage("GROUP_A", "TOPIC_A", 0, i, 1024 * 1024, null);
+ GetMessageResult result = messageStore.getMessage("GROUP_A", "FooBar", 0, i, 1024 * 1024, null);
assertThat(result).isNotNull();
result.release();
}
@@ -471,7 +471,7 @@ public class DefaultMessageStoreTest {
StoreTestUtil.waitCommitLogReput((DefaultMessageStore) messageStore);
for (long i = 0; i < totalMsgs; i++) {
- GetMessageResult result = master.getMessage("GROUP_A", "TOPIC_A", 0, i, 1024 * 1024, null);
+ GetMessageResult result = master.getMessage("GROUP_A", "FooBar", 0, i, 1024 * 1024, null);
assertThat(result).isNotNull();
result.release();