| Package | Description |
|---|---|
| com.lambdaworks.redis | |
| com.lambdaworks.redis.output | |
| com.lambdaworks.redis.protocol | |
| com.lambdaworks.redis.pubsub |
| Modifier and Type | Field and Description |
|---|---|
protected BlockingQueue<Command<K,V,?>> |
RedisAsyncConnection.queue |
| Modifier and Type | Method and Description |
|---|---|
<T> Command<K,V,T> |
RedisAsyncConnection.dispatch(CommandType type,
CommandOutput<K,V,T> output) |
<T> Command<K,V,T> |
RedisAsyncConnection.dispatch(CommandType type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args) |
<T> Command<K,V,T> |
RedisAsyncConnection.dispatch(CommandType type,
CommandOutput<K,V,T> output,
K key) |
<T> Command<K,V,T> |
RedisAsyncConnection.dispatch(CommandType type,
CommandOutput<K,V,T> output,
K key,
V value) |
<T> Command<K,V,T> |
RedisAsyncConnection.dispatch(CommandType type,
CommandOutput<K,V,T> output,
K key,
V[] values) |
| Modifier and Type | Method and Description |
|---|---|
<T> T |
RedisAsyncConnection.await(Command<K,V,T> cmd,
long timeout,
TimeUnit unit) |
| Constructor and Description |
|---|
RedisAsyncConnection(BlockingQueue<Command<K,V,?>> queue,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit)
Initialize a new connection.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MultiOutput.add(Command<K,V,?> cmd) |
| Modifier and Type | Field and Description |
|---|---|
protected BlockingQueue<Command<K,V,?>> |
CommandHandler.queue |
| Constructor and Description |
|---|
CommandHandler(BlockingQueue<Command<K,V,?>> queue)
Initialize a new instance that handles commands from the supplied queue.
|
| Constructor and Description |
|---|
PubSubCommandHandler(BlockingQueue<Command<K,V,?>> queue,
RedisCodec<K,V> codec)
Initialize a new instance.
|
RedisPubSubConnection(BlockingQueue<Command<K,V,?>> queue,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit)
Initialize a new connection.
|
Copyright © 2025. All rights reserved.