✨ Support configure database for redis (#60)

ButterCam · Jul 30, 2020 · 25847f3 · 25847f3
1 parent 67f534e
commit 25847f3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/...redis/src/main/kotlin/com/bybutter/sisyphus/middleware/redis/DefaultRedisClientFactory.kt b/...redis/src/main/kotlin/com/bybutter/sisyphus/middleware/redis/DefaultRedisClientFactory.kt
@@ -12,7 +12,8 @@ open class DefaultRedisClientFactory : RedisClientFactory {
 
     protected open fun createRedisClient(host: String, port: Int, property: RedisProperty): RedisClient {
         return clients.getOrPut("$host:$port") {
-            RedisClient.create(RedisURI.Builder.redis(host, port).withPassword(property.password).build())
+            val database = property.database ?: 0
+            RedisClient.create(RedisURI.Builder.redis(host, port).withPassword(property.password).withDatabase(database).build())
         }
     }
 }
diff --git a/...re/sisyphus-redis/src/main/kotlin/com/bybutter/sisyphus/middleware/redis/RedisProperty.kt b/...re/sisyphus-redis/src/main/kotlin/com/bybutter/sisyphus/middleware/redis/RedisProperty.kt
@@ -6,7 +6,8 @@ data class RedisProperty(
     val name: String?,
     val host: String,
     val port: Int,
-    val password: String
+    val password: String,
+    val database: Int?
 )
 
 data class RedisProperties(