update jedis config

This commit is contained in:
2025-03-23 00:14:35 +01:00
parent 6ddffa4f41
commit dd7cfb943e
2 changed files with 8 additions and 6 deletions

View File

@@ -14,11 +14,11 @@ import eventDemo.libs.event.projection.SnapshotConfig
import org.koin.core.module.Module import org.koin.core.module.Module
import org.koin.core.module.dsl.singleOf import org.koin.core.module.dsl.singleOf
import org.koin.dsl.bind import org.koin.dsl.bind
import redis.clients.jedis.JedisPool import redis.clients.jedis.JedisPooled
fun Module.configureDIInfrastructure(redisUrl: String) { fun Module.configureDIInfrastructure(redisUrl: String) {
single { single {
JedisPool(redisUrl) JedisPooled(redisUrl)
} }
singleOf(::GameEventBusInMemory) bind GameEventBus::class singleOf(::GameEventBusInMemory) bind GameEventBus::class

View File

@@ -3,16 +3,18 @@ package eventDemo.adapter.infrastructureLayer
import io.kotest.core.NamedTag import io.kotest.core.NamedTag
import io.kotest.core.spec.style.FunSpec import io.kotest.core.spec.style.FunSpec
import io.kotest.matchers.equals.shouldBeEqual import io.kotest.matchers.equals.shouldBeEqual
import redis.clients.jedis.JedisPool import redis.clients.jedis.JedisPooled
private val redisUrl = "redis://localhost:6379"
class RedisTest : class RedisTest :
FunSpec({ FunSpec({
tags(NamedTag("redis")) tags(NamedTag("redis"))
test("test connection with jedis") { test("test connection with jedis") {
JedisPool("redis://localhost:6379").apply { JedisPooled(redisUrl).also {
resource.set("test", "test") it.set("test", "test")
resource.get("test") shouldBeEqual "test" it.get("test") shouldBeEqual "test"
} }
} }
}) })