Class RedisConnectionPoolFactory<K,V>

java.lang.Object

io.micronaut.configuration.lettuce.RedisConnectionPoolFactory<K,V>

Type Parameters:

K - Key type

V - Value type

@Factory
@Requires(beans={DefaultRedisConfiguration.class,DefaultRedisConnectionPoolConfiguration.class})
public class RedisConnectionPoolFactory<K,V>
extends Object

Creates optional pooled Redis connections for cases where callers need to run work across multiple underlying Lettuce connections instead of a single long-lived connection bean.

Since:

7.0.0

Constructor Summary

Constructors

Constructor	Description
RedisConnectionPoolFactory(io.lettuce.core.codec.RedisCodec<K,V> defaultCodec)

Method Summary

Modifier and Type	Method	Description
io.lettuce.core.support.AsyncPool<io.lettuce.core.cluster.api.StatefulRedisClusterConnection<K,V>>	redisClusterConnectionPool(io.lettuce.core.cluster.RedisClusterClient redisClient, DefaultRedisConfiguration config, DefaultRedisConnectionPoolConfiguration poolConfiguration)	Creates a pool of default Redis cluster connections.
io.lettuce.core.support.AsyncPool<io.lettuce.core.api.StatefulRedisConnection<K,V>>	redisConnectionPool(io.lettuce.core.RedisClient redisClient, DefaultRedisConfiguration config, DefaultRedisConnectionPoolConfiguration poolConfiguration)	Creates a pool of default Redis connections.

Methods inherited from class Object

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

Constructor Details

RedisConnectionPoolFactory

public RedisConnectionPoolFactory(@Primary
 io.lettuce.core.codec.RedisCodec<K,V> defaultCodec)

Parameters:

defaultCodec - The default codec

Method Details

redisConnectionPool

@Bean(preDestroy="close")
@Singleton
@Primary
@Requires(beans=io.lettuce.core.RedisClient.class) @Requires(missingProperty="redis.uris")
public io.lettuce.core.support.AsyncPool<io.lettuce.core.api.StatefulRedisConnection<K,V>> redisConnectionPool(@Primary
 io.lettuce.core.RedisClient redisClient,
 @Primary
 DefaultRedisConfiguration config,
 DefaultRedisConnectionPoolConfiguration poolConfiguration)

Creates a pool of default Redis connections.

Parameters:

redisClient - The Redis client

config - The Redis configuration

poolConfiguration - The pool configuration

Returns:

The connection pool

redisClusterConnectionPool

@Bean(preDestroy="close")
@Singleton
@Primary
@Requires(beans=io.lettuce.core.cluster.RedisClusterClient.class) @Requires(property="redis.uris")
public io.lettuce.core.support.AsyncPool<io.lettuce.core.cluster.api.StatefulRedisClusterConnection<K,V>> redisClusterConnectionPool(@Primary
 io.lettuce.core.cluster.RedisClusterClient redisClient,
 @Primary
 DefaultRedisConfiguration config,
 DefaultRedisConnectionPoolConfiguration poolConfiguration)

Creates a pool of default Redis cluster connections.

Parameters:

redisClient - The Redis cluster client

config - The Redis configuration

poolConfiguration - The pool configuration

Returns:

The connection pool