[rocketmq] branch develop updated: [ISSUE #2811] Fix the wrong topic was consumed in the DefaultMessageStoreTest test program

[duhengforever]

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 <1015773...@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();