[BAEL-14848] - Fixed tests in spring-data-redis module

persistence-modules/spring-data-redis/pom.xml

@@ -79,6 +79,21 @@
         </dependency>
     </dependencies>
 
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-surefire-plugin</artifactId>
+                <version>${maven-surefire-plugin.version}</version>
+                <configuration>
+                    <verbose>true</verbose>
+                    <fork>true</fork>
+                    <argLine>-Xmx1024m</argLine>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
     <properties>
         <cglib.version>3.2.4</cglib.version>
         <jedis.version>2.9.0</jedis.version>

persistence-modules/spring-data-redis/src/test/java/com/baeldung/spring/data/reactive/redis/template/RedisKeyCommandsIntegrationTest.java

@@ -2,6 +2,9 @@ package com.baeldung.spring.data.reactive.redis.template;
 
 
 import com.baeldung.spring.data.reactive.redis.SpringRedisReactiveApplication;
+
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -9,22 +12,40 @@ import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.data.redis.connection.ReactiveKeyCommands;
 import org.springframework.data.redis.connection.ReactiveStringCommands;
 import org.springframework.data.redis.connection.ReactiveStringCommands.SetCommand;
+import org.springframework.test.annotation.DirtiesContext;
+import org.springframework.test.annotation.DirtiesContext.ClassMode;
 import org.springframework.test.context.junit4.SpringRunner;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 import reactor.test.StepVerifier;
+import redis.embedded.RedisServerBuilder;
 
+import java.io.IOException;
 import java.nio.ByteBuffer;
 
 @RunWith(SpringRunner.class)
 @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, classes = SpringRedisReactiveApplication.class)
+@DirtiesContext(classMode = ClassMode.BEFORE_CLASS)
 public class RedisKeyCommandsIntegrationTest {
+    
+    private static redis.embedded.RedisServer redisServer;
 
     @Autowired
     private ReactiveKeyCommands keyCommands;
 
     @Autowired
     private ReactiveStringCommands stringCommands;
+    
+    @BeforeClass
+    public static void startRedisServer() throws IOException {
+        redisServer = new RedisServerBuilder().port(6379).setting("maxheap 256M").build();
+        redisServer.start();
+    }
+    
+    @AfterClass
+    public static void stopRedisServer() throws IOException {
+        redisServer.stop();
+    }
 
     @Test
     public void givenFluxOfKeys_whenPerformOperations_thenPerformOperations() {

persistence-modules/spring-data-redis/src/test/java/com/baeldung/spring/data/reactive/redis/template/RedisTemplateListOpsIntegrationTest.java

@@ -2,27 +2,48 @@ package com.baeldung.spring.data.reactive.redis.template;
 
 
 import com.baeldung.spring.data.reactive.redis.SpringRedisReactiveApplication;
+
+import java.io.IOException;
+
+import org.junit.AfterClass;
 import org.junit.Before;
+import org.junit.BeforeClass;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.data.redis.core.ReactiveListOperations;
 import org.springframework.data.redis.core.ReactiveRedisTemplate;
+import org.springframework.test.annotation.DirtiesContext;
+import org.springframework.test.annotation.DirtiesContext.ClassMode;
 import org.springframework.test.context.junit4.SpringRunner;
 import reactor.core.publisher.Mono;
 import reactor.test.StepVerifier;
+import redis.embedded.RedisServerBuilder;
 
 @RunWith(SpringRunner.class)
 @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, classes = SpringRedisReactiveApplication.class)
+@DirtiesContext(classMode = ClassMode.BEFORE_CLASS)
 public class RedisTemplateListOpsIntegrationTest {
 
     private static final String LIST_NAME = "demo_list";
+    private static redis.embedded.RedisServer redisServer;
 
     @Autowired
     private ReactiveRedisTemplate<String, String> redisTemplate;
 
     private ReactiveListOperations<String, String> reactiveListOps;
+    
+    @BeforeClass
+    public static void startRedisServer() throws IOException {
+        redisServer = new RedisServerBuilder().port(6379).setting("maxheap 128M").build();
+        redisServer.start();
+    }
+    
+    @AfterClass
+    public static void stopRedisServer() throws IOException {
+        redisServer.stop();
+    }
 
     @Before
     public void setup() {

persistence-modules/spring-data-redis/src/test/java/com/baeldung/spring/data/reactive/redis/template/RedisTemplateValueOpsIntegrationTest.java

@@ -1,29 +1,51 @@
 package com.baeldung.spring.data.reactive.redis.template;
 
 
-import com.baeldung.spring.data.reactive.redis.SpringRedisReactiveApplication;
-import com.baeldung.spring.data.reactive.redis.model.Employee;
+import java.io.IOException;
+import java.time.Duration;
+
+import org.junit.AfterClass;
 import org.junit.Before;
+import org.junit.BeforeClass;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.data.redis.core.ReactiveRedisTemplate;
 import org.springframework.data.redis.core.ReactiveValueOperations;
+import org.springframework.test.annotation.DirtiesContext;
+import org.springframework.test.annotation.DirtiesContext.ClassMode;
 import org.springframework.test.context.junit4.SpringRunner;
+
+import com.baeldung.spring.data.reactive.redis.SpringRedisReactiveApplication;
+import com.baeldung.spring.data.reactive.redis.model.Employee;
+
 import reactor.core.publisher.Mono;
 import reactor.test.StepVerifier;
-
-import java.time.Duration;
+import redis.embedded.RedisServerBuilder;
 
 @RunWith(SpringRunner.class)
 @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, classes = SpringRedisReactiveApplication.class)
+@DirtiesContext(classMode = ClassMode.BEFORE_CLASS)
 public class RedisTemplateValueOpsIntegrationTest {
+    
+    private static redis.embedded.RedisServer redisServer;
 
     @Autowired
     private ReactiveRedisTemplate<String, Employee> redisTemplate;
 
     private ReactiveValueOperations<String, Employee> reactiveValueOps;
+    
+    @BeforeClass
+    public static void startRedisServer() throws IOException {
+        redisServer = new RedisServerBuilder().port(6379).setting("maxheap 256M").build();
+        redisServer.start();
+    }
+    
+    @AfterClass
+    public static void stopRedisServer() throws IOException {
+        redisServer.stop();
+    }
 
     @Before
     public void setup() {

persistence-modules/spring-data-redis/src/test/java/com/baeldung/spring/data/redis/RedisMessageListenerIntegrationTest.java

@@ -19,9 +19,11 @@ import com.baeldung.spring.data.redis.config.RedisConfig;
 import com.baeldung.spring.data.redis.queue.RedisMessagePublisher;
 import com.baeldung.spring.data.redis.queue.RedisMessageSubscriber;
 
+import redis.embedded.RedisServerBuilder;
+
 @RunWith(SpringJUnit4ClassRunner.class)
 @ContextConfiguration(classes = RedisConfig.class)
-@DirtiesContext(classMode = ClassMode.AFTER_CLASS)
+@DirtiesContext(classMode = ClassMode.BEFORE_CLASS)
 public class RedisMessageListenerIntegrationTest {
 
     private static redis.embedded.RedisServer redisServer;
@@ -31,7 +33,7 @@ public class RedisMessageListenerIntegrationTest {
     
     @BeforeClass
     public static void startRedisServer() throws IOException {
-        redisServer = new redis.embedded.RedisServer(6380);
+        redisServer = new RedisServerBuilder().port(6379).setting("maxheap 256M").build();
         redisServer.start();
     }
     

persistence-modules/spring-data-redis/src/test/java/com/baeldung/spring/data/redis/repo/StudentRepositoryIntegrationTest.java

@@ -20,9 +20,11 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 import com.baeldung.spring.data.redis.config.RedisConfig;
 import com.baeldung.spring.data.redis.model.Student;
 
+import redis.embedded.RedisServerBuilder;
+
 @RunWith(SpringJUnit4ClassRunner.class)
 @ContextConfiguration(classes = RedisConfig.class)
-@DirtiesContext(classMode = ClassMode.AFTER_CLASS)
+@DirtiesContext(classMode = ClassMode.BEFORE_CLASS)
 public class StudentRepositoryIntegrationTest {
 
     @Autowired
@@ -32,7 +34,7 @@ public class StudentRepositoryIntegrationTest {
     
     @BeforeClass
     public static void startRedisServer() throws IOException {
-        redisServer = new redis.embedded.RedisServer(6380);
+        redisServer = new RedisServerBuilder().port(6379).setting("maxheap 128M").build();
         redisServer.start();
     }