public class RedisClientBase extends Object
Modifier and Type | Field and Description |
---|---|
static byte[] |
ALPHA |
protected static String |
AUTH |
protected static byte[] |
AUTH_BYTES |
static byte[] |
BY |
static byte[] |
DESC |
static byte[] |
GET |
static byte[] |
LIMIT |
protected AtomicInteger |
pipelined |
protected RedisProtocol |
redisProtocol |
static byte[] |
STORE |
protected int |
version |
static byte[] |
WEIGHTS |
static byte[] |
WITHSCORES |
Modifier | Constructor and Description |
---|---|
protected |
RedisClientBase(String host,
int port,
ExecutorService executorService) |
Modifier and Type | Method and Description |
---|---|
void |
addListener(ReplyListener replyListener)
Add a reply listener to this client for subscriptions.
|
StatusReply |
auth(Object password0)
Authenticate to the server
Connection
|
void |
close() |
StatusReply |
discard() |
Future<Boolean> |
exec() |
Reply |
execute(String name,
Command command) |
RedisProtocol |
getRedisProtocol() |
StatusReply |
multi() |
static int |
parseVersion(String value) |
com.google.common.util.concurrent.ListenableFuture<? extends Reply> |
pipeline(String name,
Command command) |
void |
psubscribe(Object... subscriptions)
Subscribes the client to the specified patterns.
|
void |
punsubscribe(Object... subscriptions)
Unsubscribes the client to the specified patterns.
|
boolean |
removeListener(ReplyListener replyListener)
Remove a reply listener from this client.
|
void |
subscribe(Object... subscriptions)
Subscribes the client to the specified channels.
|
void |
unsubscribe(Object... subscriptions)
Unsubscribes the client to the specified channels.
|
public static final byte[] WEIGHTS
public static final byte[] WITHSCORES
public static final byte[] ALPHA
public static final byte[] LIMIT
public static final byte[] DESC
public static final byte[] BY
public static final byte[] STORE
public static final byte[] GET
protected RedisProtocol redisProtocol
protected AtomicInteger pipelined
protected int version
protected static final String AUTH
protected static final byte[] AUTH_BYTES
protected RedisClientBase(String host, int port, ExecutorService executorService) throws RedisException
RedisException
public static int parseVersion(String value)
public com.google.common.util.concurrent.ListenableFuture<? extends Reply> pipeline(String name, Command command) throws RedisException
RedisException
public Reply execute(String name, Command command) throws RedisException
RedisException
public RedisProtocol getRedisProtocol()
public void close() throws IOException
IOException
public StatusReply multi()
public StatusReply discard()
public void addListener(ReplyListener replyListener)
public boolean removeListener(ReplyListener replyListener)
public void subscribe(Object... subscriptions)
subscriptions
- public void psubscribe(Object... subscriptions)
subscriptions
- public void unsubscribe(Object... subscriptions)
subscriptions
- public void punsubscribe(Object... subscriptions)
subscriptions
- public StatusReply auth(Object password0) throws RedisException
password0
- RedisException
Copyright © 2015. All rights reserved.