From dd7cfb943eba42a1c9f7079ee112c1143a80377f Mon Sep 17 00:00:00 2001 From: Fabrice Lecomte Date: Sun, 23 Mar 2025 00:14:35 +0100 Subject: [PATCH] update jedis config --- .../injection/ConfigureDIInfrastructure.kt | 4 ++-- .../eventDemo/adapter/infrastructureLayer/RedisTest.kt | 10 ++++++---- 2 files changed, 8 insertions(+), 6 deletions(-) diff --git a/src/main/kotlin/eventDemo/configuration/injection/ConfigureDIInfrastructure.kt b/src/main/kotlin/eventDemo/configuration/injection/ConfigureDIInfrastructure.kt index cca364e..d2ef60a 100644 --- a/src/main/kotlin/eventDemo/configuration/injection/ConfigureDIInfrastructure.kt +++ b/src/main/kotlin/eventDemo/configuration/injection/ConfigureDIInfrastructure.kt @@ -14,11 +14,11 @@ import eventDemo.libs.event.projection.SnapshotConfig import org.koin.core.module.Module import org.koin.core.module.dsl.singleOf import org.koin.dsl.bind -import redis.clients.jedis.JedisPool +import redis.clients.jedis.JedisPooled fun Module.configureDIInfrastructure(redisUrl: String) { single { - JedisPool(redisUrl) + JedisPooled(redisUrl) } singleOf(::GameEventBusInMemory) bind GameEventBus::class diff --git a/src/test/kotlin/eventDemo/adapter/infrastructureLayer/RedisTest.kt b/src/test/kotlin/eventDemo/adapter/infrastructureLayer/RedisTest.kt index 2cf61dd..b4756ee 100644 --- a/src/test/kotlin/eventDemo/adapter/infrastructureLayer/RedisTest.kt +++ b/src/test/kotlin/eventDemo/adapter/infrastructureLayer/RedisTest.kt @@ -3,16 +3,18 @@ package eventDemo.adapter.infrastructureLayer import io.kotest.core.NamedTag import io.kotest.core.spec.style.FunSpec import io.kotest.matchers.equals.shouldBeEqual -import redis.clients.jedis.JedisPool +import redis.clients.jedis.JedisPooled + +private val redisUrl = "redis://localhost:6379" class RedisTest : FunSpec({ tags(NamedTag("redis")) test("test connection with jedis") { - JedisPool("redis://localhost:6379").apply { - resource.set("test", "test") - resource.get("test") shouldBeEqual "test" + JedisPooled(redisUrl).also { + it.set("test", "test") + it.get("test") shouldBeEqual "test" } } })