StakeSquid/dshackle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

problem: confusing stack trace when cannot connect to Redis

Browse Source
This commit is contained in:
Igor Artamonov
2020-05-27 17:43:17 -04:00
parent aaf79ad643
commit 3ff61b735a
1 changed files with 24 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
src/main/kotlin/io/emeraldpay/dshackle/cache/CachesFactory.kt vendored
View File

@@ -19,6 +19,7 @@ import com.fasterxml.jackson.databind.ObjectMapper
import io.emeraldpay.dshackle.config.CacheConfig import io.emeraldpay.dshackle.config.CacheConfig
import io.emeraldpay.grpc.Chain import io.emeraldpay.grpc.Chain
import io.lettuce.core.RedisClient import io.lettuce.core.RedisClient
import io.lettuce.core.RedisConnectionException
import io.lettuce.core.RedisURI import io.lettuce.core.RedisURI
import io.lettuce.core.api.StatefulRedisConnection import io.lettuce.core.api.StatefulRedisConnection
import io.lettuce.core.codec.ByteArrayCodec import io.lettuce.core.codec.ByteArrayCodec
@@ -29,6 +30,7 @@ import org.springframework.beans.factory.annotation.Autowired
import org.springframework.stereotype.Repository import org.springframework.stereotype.Repository
import java.util.* import java.util.*
import javax.annotation.PostConstruct import javax.annotation.PostConstruct
import kotlin.system.exitProcess
@Repository @Repository
@@ -64,11 +66,29 @@ class CachesFactory(
} }
val client = RedisClient.create(uri.build()) val client = RedisClient.create(uri.build())
val ping = client.connect().sync().ping() try {
if (ping != "PONG") { val ping = client.connect().sync().ping()
throw IllegalStateException("Redis connection is not configured. Response: $ping") if (ping != "PONG") {
throw IllegalStateException("Redis connection is not configured. Response: $ping")
}
log.info("Connection to Redis established")
redis = client.connect(RedisCodec.of(StringCodec.ASCII, ByteArrayCodec.INSTANCE))
} catch (e: RedisConnectionException) {
log.error("Unable to establish connection to the Redis server")
log.error("Redis error: ${e.message}")
log.error("Redis config: ")
log.error(" uri: ${redisConfig.host}:${redisConfig.port}")
redisConfig.db?.let {
log.error(" db: $it")
}
if (redisConfig.password != null && redisConfig.password!!.isNotBlank()) {
log.error(" password: (set)")
} else {
log.error(" password: (not set)")
}
log.error("Stopping the server...")
exitProcess(1)
} }
redis = client.connect(RedisCodec.of(StringCodec.ASCII, ByteArrayCodec.INSTANCE))
} }
private fun initCache(chain: Chain): Caches { private fun initCache(chain: Chain): Caches {