BAEL-3275: Convert RedisMessageListenerIntegrationTest to a SpringBootTest (#9717)
This commit is contained in:
parent
93eb539b90
commit
9cf9cf91a2
|
@ -0,0 +1,13 @@
|
||||||
|
package com.baeldung.spring.data.redis;
|
||||||
|
|
||||||
|
import org.springframework.boot.SpringApplication;
|
||||||
|
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
||||||
|
|
||||||
|
@SpringBootApplication
|
||||||
|
public class SpringRedisApplication {
|
||||||
|
|
||||||
|
public static void main(String[] args) {
|
||||||
|
SpringApplication.run(SpringRedisApplication.class, args);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
|
@ -1,44 +1,40 @@
|
||||||
package com.baeldung.spring.data.redis;
|
package com.baeldung.spring.data.redis;
|
||||||
|
|
||||||
import static org.junit.Assert.assertTrue;
|
import com.baeldung.spring.data.redis.queue.RedisMessagePublisher;
|
||||||
|
import com.baeldung.spring.data.redis.queue.RedisMessageSubscriber;
|
||||||
import java.io.IOException;
|
|
||||||
import java.util.UUID;
|
|
||||||
|
|
||||||
import org.junit.AfterClass;
|
import org.junit.AfterClass;
|
||||||
import org.junit.BeforeClass;
|
import org.junit.BeforeClass;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
import org.junit.runner.RunWith;
|
import org.junit.runner.RunWith;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
import org.springframework.boot.test.context.SpringBootTest;
|
||||||
import org.springframework.test.annotation.DirtiesContext;
|
import org.springframework.test.annotation.DirtiesContext;
|
||||||
import org.springframework.test.annotation.DirtiesContext.ClassMode;
|
import org.springframework.test.annotation.DirtiesContext.ClassMode;
|
||||||
import org.springframework.test.context.ContextConfiguration;
|
import org.springframework.test.context.junit4.SpringRunner;
|
||||||
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
|
|
||||||
|
|
||||||
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;
|
import redis.embedded.RedisServerBuilder;
|
||||||
|
|
||||||
@RunWith(SpringJUnit4ClassRunner.class)
|
import java.util.UUID;
|
||||||
@ContextConfiguration(classes = RedisConfig.class)
|
|
||||||
|
import static org.junit.Assert.assertTrue;
|
||||||
|
|
||||||
|
@RunWith(SpringRunner.class)
|
||||||
|
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, classes = SpringRedisApplication.class)
|
||||||
@DirtiesContext(classMode = ClassMode.BEFORE_CLASS)
|
@DirtiesContext(classMode = ClassMode.BEFORE_CLASS)
|
||||||
public class RedisMessageListenerIntegrationTest {
|
public class RedisMessageListenerIntegrationTest {
|
||||||
|
|
||||||
private static redis.embedded.RedisServer redisServer;
|
private static redis.embedded.RedisServer redisServer;
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
private RedisMessagePublisher redisMessagePublisher;
|
private RedisMessagePublisher redisMessagePublisher;
|
||||||
|
|
||||||
@BeforeClass
|
@BeforeClass
|
||||||
public static void startRedisServer() throws IOException {
|
public static void startRedisServer() {
|
||||||
redisServer = new RedisServerBuilder().port(6379).setting("maxmemory 256M").build();
|
redisServer = new RedisServerBuilder().port(6379).setting("maxmemory 256M").build();
|
||||||
redisServer.start();
|
redisServer.start();
|
||||||
}
|
}
|
||||||
|
|
||||||
@AfterClass
|
@AfterClass
|
||||||
public static void stopRedisServer() throws IOException {
|
public static void stopRedisServer() {
|
||||||
redisServer.stop();
|
redisServer.stop();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue