@Internal
public class RedisConnectionUtil
extends java.lang.Object
Constructor and Description |
---|
RedisConnectionUtil() |
Modifier and Type | Method and Description |
---|---|
static io.lettuce.core.AbstractRedisClient |
findClient(io.micronaut.context.BeanLocator beanLocator,
java.util.Optional<java.lang.String> serverName,
java.lang.String errorMessage)
Utility method for establishing a redis connection.
|
static io.lettuce.core.api.StatefulConnection |
findRedisConnection(io.micronaut.context.BeanLocator beanLocator,
java.util.Optional<java.lang.String> serverName,
java.lang.String errorMessage)
Utility method for establishing a redis connection.
|
static io.lettuce.core.api.StatefulConnection<byte[],byte[]> |
openBytesRedisConnection(io.micronaut.context.BeanLocator beanLocator,
java.util.Optional<java.lang.String> serverName,
java.lang.String errorMessage)
Utility method for opening a new bytes redis connection.
|
@NonNull public static io.lettuce.core.AbstractRedisClient findClient(io.micronaut.context.BeanLocator beanLocator, java.util.Optional<java.lang.String> serverName, java.lang.String errorMessage)
beanLocator
- The bean locator to useserverName
- The server name to useerrorMessage
- The error message to use if the connection can't be foundio.micronaut.context.exceptions.ConfigurationException
- If the connection cannot be foundpublic static io.lettuce.core.api.StatefulConnection findRedisConnection(io.micronaut.context.BeanLocator beanLocator, java.util.Optional<java.lang.String> serverName, java.lang.String errorMessage)
beanLocator
- The bean locator to useserverName
- The server name to useerrorMessage
- The error message to use if the connection can't be foundio.micronaut.context.exceptions.ConfigurationException
- If the connection cannot be foundpublic static io.lettuce.core.api.StatefulConnection<byte[],byte[]> openBytesRedisConnection(io.micronaut.context.BeanLocator beanLocator, java.util.Optional<java.lang.String> serverName, java.lang.String errorMessage)
beanLocator
- The bean locator to useserverName
- The server name to useerrorMessage
- The error message to use if the connection can't be foundio.micronaut.context.exceptions.ConfigurationException
- If the connection cannot be found