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);