fix: added missing before and after methods

src/test/java/org/redisson/RedissonCountDownLatchConcurrentTest.java

@@ -1,16 +1,29 @@
 package org.redisson;
 
+import java.io.IOException;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
+import org.junit.After;
 
 import org.junit.Assert;
+import org.junit.Before;
 import org.junit.Test;
 import org.redisson.core.RCountDownLatch;
 
 public class RedissonCountDownLatchConcurrentTest {
     
+    @Before
+    public void before() throws IOException, InterruptedException {
+        RedisRunner.startDefaultRedisTestInstance();
+    }
+
+    @After
+    public void after() throws InterruptedException {
+        RedisRunner.shutDownDefaultRedisTestInstance();
+    }
+
     @Test
     public void testSingleCountDownAwait_SingleInstance() throws InterruptedException {
         final int iterations = Runtime.getRuntime().availableProcessors()*3;

src/test/java/org/redisson/RedissonTest.java

@@ -10,9 +10,11 @@ import java.util.Map;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 import java.util.concurrent.atomic.AtomicInteger;
+import org.junit.After;
 
 import org.junit.Assert;
 import org.junit.Assume;
+import org.junit.Before;
 import org.junit.Test;
 import org.redisson.RedisRunner.RedisProcess;
 import org.redisson.client.RedisConnectionException;
@@ -28,6 +30,16 @@ public class RedissonTest {
 
     RedissonClient redisson;
 
+    @Before
+    public void before() throws IOException, InterruptedException {
+        RedisRunner.startDefaultRedisTestInstance();
+    }
+
+    @After
+    public void after() throws InterruptedException {
+        RedisRunner.shutDownDefaultRedisTestInstance();
+    }
+
     public static class Dummy {
         private String field;
     }

src/test/java/org/redisson/RedissonTopicPatternTest.java

@@ -1,9 +1,12 @@
 package org.redisson;
 
+import java.io.IOException;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
+import org.junit.After;
 
 import org.junit.Assert;
+import org.junit.Before;
 import org.junit.Test;
 import org.redisson.core.BasePatternStatusListener;
 import org.redisson.core.MessageListener;
@@ -13,6 +16,16 @@ import org.redisson.core.RTopic;
 
 public class RedissonTopicPatternTest {
     
+    @Before
+    public void before() throws IOException, InterruptedException {
+        RedisRunner.startDefaultRedisTestInstance();
+    }
+
+    @After
+    public void after() throws InterruptedException {
+        RedisRunner.shutDownDefaultRedisTestInstance();
+    }
+
     public static class Message {
 
         private String name;

src/test/java/org/redisson/RedissonTopicTest.java

@@ -1,10 +1,13 @@
 package org.redisson;
 
+import java.io.IOException;
 import java.io.Serializable;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
+import org.junit.After;
 
 import org.junit.Assert;
+import org.junit.Before;
 import org.junit.Test;
 import org.redisson.core.BaseStatusListener;
 import org.redisson.core.MessageListener;
@@ -13,6 +16,16 @@ import org.redisson.core.RTopic;
 
 public class RedissonTopicTest {
     
+    @Before
+    public void before() throws IOException, InterruptedException {
+        RedisRunner.startDefaultRedisTestInstance();
+    }
+
+    @After
+    public void after() throws InterruptedException {
+        RedisRunner.shutDownDefaultRedisTestInstance();
+    }
+
     public static class Message implements Serializable {
 
         private String name;