fix(redis): add max pool wait time and switch to ReactiveRedisDataSource for heartbeat updates

modules/core/src/main/resources/application.yml

@@ -5,6 +5,7 @@ quarkus:
     name: nowchess-core
   redis:
     hosts: redis://${REDIS_HOST:localhost}:${REDIS_PORT:6379}
+    max-pool-wait-time: 500ms
   grpc:
     clients:
       rule-grpc:

modules/core/src/main/scala/de/nowchess/chess/service/InstanceHeartbeatService.scala

@@ -8,6 +8,7 @@ import io.quarkus.runtime.ShutdownEvent
 import io.quarkus.grpc.GrpcClient
 import org.eclipse.microprofile.config.inject.ConfigProperty
 import io.quarkus.redis.datasource.RedisDataSource
+import io.quarkus.redis.datasource.ReactiveRedisDataSource
 import scala.compiletime.uninitialized
 import java.util.concurrent.{Executors, TimeUnit}
 import java.net.InetAddress
@@ -24,6 +25,9 @@ class InstanceHeartbeatService:
   @Inject
   private var redis: RedisDataSource = uninitialized
 
+  @Inject
+  private var reactiveRedis: ReactiveRedisDataSource = uninitialized
+
   @Inject
   private var mapper: ObjectMapper = uninitialized
 
@@ -182,10 +186,14 @@ class InstanceHeartbeatService:
       )
 
       val json = mapper.writeValueAsString(metadata)
-      redis.value(classOf[String]).setex(key, 5L, json)
+      reactiveRedis.value(classOf[String]).setex(key, 5L, json)
+        .subscribe().`with`(
+          _ => (),
+          (ex: Throwable) => log.warnf(ex, "Failed to refresh Redis heartbeat"),
+        )
     catch
       case ex: Exception =>
-        log.warnf(ex, "Failed to refresh Redis heartbeat")
+        log.warnf(ex, "Failed to serialize Redis heartbeat metadata")
 
   private def getHostname: String =
     try InetAddress.getLocalHost.getHostName