Package dev.unnm3d.redischat.datamanagers.redistools

Class RedisAbstract

java.lang.Object

dev.unnm3d.redischat.datamanagers.redistools.RedisAbstract

Direct Known Subclasses:

RedisDataManager

public abstract class RedisAbstract
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected io.lettuce.core.RedisClient	lettuceRedisClient

Constructor Summary

Constructors

Constructor	Description
RedisAbstract(io.lettuce.core.RedisClient lettuceRedisClient, int poolSize)

Method Summary

Modifier and Type	Method	Description
void	close()
Optional<List<Object>>	executeTransaction(Consumer<io.lettuce.core.api.sync.RedisCommands<String,String>> redisCommandsConsumer)
<T> CompletionStage<T>	getConnectionAsync(Function<io.lettuce.core.api.async.RedisAsyncCommands<String,String>,CompletionStage<T>> redisCallBack)
<T> CompletionStage<T>	getConnectionPipeline(Function<io.lettuce.core.api.async.RedisAsyncCommands<String,String>,CompletionStage<T>> redisCallBack)
abstract void	receiveMessage(String channel, String message)
protected void	registerSub(String... listenedChannels)

Methods inherited from class java.lang.Object

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

Field Details

lettuceRedisClient

protected io.lettuce.core.RedisClient lettuceRedisClient

Constructor Details

RedisAbstract

public RedisAbstract(io.lettuce.core.RedisClient lettuceRedisClient,
 int poolSize)

Method Details

receiveMessage

public abstract void receiveMessage(String channel,
 String message)

registerSub

protected void registerSub(String... listenedChannels)

getConnectionAsync

public <T> CompletionStage<T> getConnectionAsync(Function<io.lettuce.core.api.async.RedisAsyncCommands<String,String>,CompletionStage<T>> redisCallBack)

getConnectionPipeline

public <T> CompletionStage<T> getConnectionPipeline(Function<io.lettuce.core.api.async.RedisAsyncCommands<String,String>,CompletionStage<T>> redisCallBack)

executeTransaction

public Optional<List<Object>> executeTransaction(Consumer<io.lettuce.core.api.sync.RedisCommands<String,String>> redisCommandsConsumer)

close

public void close()