io.micronaut.configuration.lettuce

Class DefaultRedisClusterClientFactory

java.lang.Object

io.micronaut.configuration.lettuce.DefaultRedisClusterClientFactory

@Requires(property="redis.uris")
 @Singleton
 @Factory
public class DefaultRedisClusterClientFactory
extends Object

Allows connecting to a Redis cluster via the the "redis.uris" setting.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor and Description
DefaultRedisClusterClientFactory()

Method Summary

Modifier and Type	Method and Description
io.lettuce.core.cluster.RedisClusterClient	redisClient(AbstractRedisConfiguration config) Create the client based on config URIs.
io.lettuce.core.cluster.api.StatefulRedisClusterConnection<String,String>	redisConnection(io.lettuce.core.cluster.RedisClusterClient redisClient) Establish redis connection.
io.lettuce.core.pubsub.StatefulRedisPubSubConnection<String,String>	redisPubSubConnection(io.lettuce.core.cluster.RedisClusterClient redisClient)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultRedisClusterClientFactory

public DefaultRedisClusterClientFactory()

Method Detail

redisClient

@Bean(preDestroy="shutdown")
 @Singleton
 @Primary
public io.lettuce.core.cluster.RedisClusterClient redisClient(@Primary
                                                                                                                 AbstractRedisConfiguration config)

Create the client based on config URIs.

Parameters:

config - config

Returns:

client

redisConnection

@Bean(preDestroy="close")
 @Singleton
 @Primary
public io.lettuce.core.cluster.api.StatefulRedisClusterConnection<String,String> redisConnection(@Primary
                                                                                                                                                 io.lettuce.core.cluster.RedisClusterClient redisClient)

Establish redis connection.

Parameters:

redisClient - client.

Returns:

connection

redisPubSubConnection

@Bean(preDestroy="close")
 @Singleton
public io.lettuce.core.pubsub.StatefulRedisPubSubConnection<String,String> redisPubSubConnection(@Primary
                                                                                                                                       io.lettuce.core.cluster.RedisClusterClient redisClient)

Parameters:

redisClient - redisClient

Returns:

connection