diff --git a/session-redis-webflux/src/aotTest/java/com/example/session/redis/webflux/SessionRedisWebfluxApplicationTests.java b/session-redis-webflux/src/aotTest/java/com/example/session/redis/webflux/SessionRedisWebfluxApplicationTests.java index 381bba77..8851697c 100644 --- a/session-redis-webflux/src/aotTest/java/com/example/session/redis/webflux/SessionRedisWebfluxApplicationTests.java +++ b/session-redis-webflux/src/aotTest/java/com/example/session/redis/webflux/SessionRedisWebfluxApplicationTests.java @@ -13,12 +13,12 @@ public class SessionRedisWebfluxApplicationTests { @Test void shouldIncreaseCounter(WebTestClient client) { AtomicReference sessionId = new AtomicReference<>(); - client.get().uri("/counter").exchange().expectCookie().value("SESSION", sessionId::set).expectBody() - .jsonPath("$.counter").isEqualTo(1); - client.get().uri("/counter").cookie("SESSION", sessionId.get()).exchange().expectBody().jsonPath("$.counter") - .isEqualTo(2); - client.get().uri("/counter").cookie("SESSION", sessionId.get()).exchange().expectBody().jsonPath("$.counter") - .isEqualTo(3); + client.get().uri("/counter").exchange().expectStatus().isOk().expectCookie().value("SESSION", sessionId::set) + .expectBody().jsonPath("$.counter").isEqualTo(1); + client.get().uri("/counter").cookie("SESSION", sessionId.get()).exchange().expectStatus().isOk().expectBody() + .jsonPath("$.counter").isEqualTo(2); + client.get().uri("/counter").cookie("SESSION", sessionId.get()).exchange().expectStatus().isOk().expectBody() + .jsonPath("$.counter").isEqualTo(3); } } diff --git a/session-redis-webflux/src/main/java/com/example/session/redis/webflux/SessionConfig.java b/session-redis-webflux/src/main/java/com/example/session/redis/webflux/SessionConfig.java index af9e63e9..360e857e 100644 --- a/session-redis-webflux/src/main/java/com/example/session/redis/webflux/SessionConfig.java +++ b/session-redis-webflux/src/main/java/com/example/session/redis/webflux/SessionConfig.java @@ -15,7 +15,9 @@ class SessionConfig { @Bean LettuceConnectionFactory redisConnectionFactory() { - return new LettuceConnectionFactory(); + String redisHost = System.getenv().getOrDefault("REDIS_HOST", "localhost"); + String port = System.getenv().getOrDefault("REDIS_PORT_6379", "6379"); + return new LettuceConnectionFactory(redisHost, Integer.parseInt(port)); } @Bean diff --git a/session-redis-webflux/src/main/resources/application.properties b/session-redis-webflux/src/main/resources/application.properties deleted file mode 100644 index 18d789a6..00000000 --- a/session-redis-webflux/src/main/resources/application.properties +++ /dev/null @@ -1,2 +0,0 @@ -spring.redis.host=${REDIS_HOST:localhost} -spring.redis.port=${REDIS_PORT_6379:6379}