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 2019/02/21 09:46:22 UTC

[rocketmq] branch develop updated: [RIP-10] Fix junit bug in ScheduleMessageServiceTest (#839)

This is an automated email from the ASF dual-hosted git repository.

dinglei 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 cbba3f6  [RIP-10] Fix junit bug in ScheduleMessageServiceTest (#839)
cbba3f6 is described below

commit cbba3f621ab498360bd4031b826c65510a2dd1ed
Author: ranqiqiang <qi...@gmail.com>
AuthorDate: Thu Feb 21 17:46:18 2019 +0800

    [RIP-10] Fix junit bug in ScheduleMessageServiceTest (#839)
    
    [RIP-10] Fix junit bug in ScheduleMessageServiceTest
---
 .../org/apache/rocketmq/store/schedule/ScheduleMessageServiceTest.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/store/src/test/java/org/apache/rocketmq/store/schedule/ScheduleMessageServiceTest.java b/store/src/test/java/org/apache/rocketmq/store/schedule/ScheduleMessageServiceTest.java
index e8c9d12..dc05c3b 100644
--- a/store/src/test/java/org/apache/rocketmq/store/schedule/ScheduleMessageServiceTest.java
+++ b/store/src/test/java/org/apache/rocketmq/store/schedule/ScheduleMessageServiceTest.java
@@ -36,6 +36,7 @@ import java.nio.ByteBuffer;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.UUID;
 import java.util.concurrent.TimeUnit;
 
 import static org.assertj.core.api.Assertions.assertThat;
@@ -54,7 +55,7 @@ public class ScheduleMessageServiceTest {
      */
     int delayLevel = 1;
 
-    private static final String storePath = System.getProperty("user.home")  + File.separator + "schedule_test";
+    private static final String storePath = System.getProperty("user.home")  + File.separator + "schedule_test"+ UUID.randomUUID();
     private static final int commitLogFileSize = 1024;
     private static final int cqFileSize = 10;
     private static final int cqExtFileSize = 10 * (ConsumeQueueExt.CqExtUnit.MIN_EXT_UNIT_SIZE + 64);