RedisClientBase

java.lang.Object
- redis.client.RedisClientBase

Direct Known Subclasses:

RedisClient
```
public class RedisClientBase
extends java.lang.Object
```
The lowest layer that talks directly with the redis protocol.
User: sam Date: 11/5/11 Time: 10:24 PM

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

private class RedisClientBase.SubscriptionsDispatcher

Nested Classes
Modifier and Type	Class and Description
`private class`	`RedisClientBase.SubscriptionsDispatcher`

Field Summary

Fields
Modifier and Type	Field and Description
`static byte[]`	`ALPHA`
`protected static java.lang.String`	`AUTH`
`protected static byte[]`	`AUTH_BYTES`
`static byte[]`	`BY`
`private static java.util.Comparator<byte[]>`	`BYTES`
`static byte[]`	`DESC`
`private static Command`	`DISCARD`
`private com.google.common.util.concurrent.ListeningExecutorService`	`es`
`private static Command`	`EXEC`
`static byte[]`	`GET`
`private java.lang.String`	`host`
`static byte[]`	`LIMIT`
`private static byte[]`	`MESSAGE`
`private static Command`	`MULTI` Transaction support
`private boolean`	`parseAttempted`
`protected java.util.concurrent.atomic.AtomicInteger`	`pipelined`
`private static byte[]`	`PMESSAGE`
`private int`	`port`
`private static byte[]`	`PSUBSCRIBE`
`private static byte[]`	`PUNSUBSCRIBE`
`protected RedisProtocol`	`redisProtocol`
`private java.util.List<ReplyListener>`	`replyListeners`
`private boolean`	`retrying`
`static byte[]`	`STORE`
`private static byte[]`	`SUBSCRIBE`
`private boolean`	`subscribed`
`private boolean`	`tx`
`private java.util.Queue<com.google.common.util.concurrent.SettableFuture<Reply>>`	`txReplies`
`private static byte[]`	`UNSUBSCRIBE`
`protected int`	`version`
`private static java.util.regex.Pattern`	`versionMatcher`
`static byte[]`	`WEIGHTS`
`static byte[]`	`WITHSCORES`

Constructor Summary

Constructors
Modifier	Constructor and Description
`protected`	`RedisClientBase(java.lang.String host, int port, java.util.concurrent.ExecutorService executorService)`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`addListener(ReplyListener replyListener)` Add a reply listener to this client for subscriptions.
`StatusReply`	`auth(java.lang.Object password0)` Authenticate to the server Connection
`void`	`close()`
`private boolean`	`connect()`
`StatusReply`	`discard()`
`java.util.concurrent.Future<java.lang.Boolean>`	`exec()`
`Reply`	`execute(java.lang.String name, Command command)`
`RedisProtocol`	`getRedisProtocol()`
`StatusReply`	`multi()`
`private void`	`parseInfo()`
`static int`	`parseVersion(java.lang.String value)`
`com.google.common.util.concurrent.ListenableFuture<? extends Reply>`	`pipeline(java.lang.String name, Command command)`
`void`	`psubscribe(java.lang.Object... subscriptions)` Subscribes the client to the specified patterns.
`void`	`punsubscribe(java.lang.Object... subscriptions)` Unsubscribes the client to the specified patterns.
`boolean`	`removeListener(ReplyListener replyListener)` Remove a reply listener from this client.
`private void`	`subscribe()`
`void`	`subscribe(java.lang.Object... subscriptions)` Subscribes the client to the specified channels.
`void`	`unsubscribe(java.lang.Object... subscriptions)` Unsubscribes the client to the specified channels.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

BYTES

private static final java.util.Comparator<byte[]> BYTES

WEIGHTS
```
public static final byte[] WEIGHTS
```

WITHSCORES
```
public static final byte[] WITHSCORES
```

ALPHA
```
public static final byte[] ALPHA
```

LIMIT
```
public static final byte[] LIMIT
```

DESC
```
public static final byte[] DESC
```

BY
```
public static final byte[] BY
```

STORE
```
public static final byte[] STORE
```

GET
```
public static final byte[] GET
```

host
```
private final java.lang.String host
```

port
```
private final int port
```

es

private com.google.common.util.concurrent.ListeningExecutorService es

redisProtocol
```
protected RedisProtocol redisProtocol
```

versionMatcher

private static final java.util.regex.Pattern versionMatcher

pipelined

protected java.util.concurrent.atomic.AtomicInteger pipelined

version
```
protected int version
```

parseAttempted
```
private boolean parseAttempted
```

txReplies

private java.util.Queue<com.google.common.util.concurrent.SettableFuture<Reply>> txReplies

retrying
```
private boolean retrying
```

MULTI
```
private static final Command MULTI
```
Transaction support

EXEC
```
private static final Command EXEC
```

DISCARD
```
private static final Command DISCARD
```

tx
```
private boolean tx
```

replyListeners

private java.util.List<ReplyListener> replyListeners

subscribed
```
private boolean subscribed
```

MESSAGE
```
private static final byte[] MESSAGE
```

PMESSAGE
```
private static final byte[] PMESSAGE
```

SUBSCRIBE
```
private static final byte[] SUBSCRIBE
```

UNSUBSCRIBE

private static final byte[] UNSUBSCRIBE

PSUBSCRIBE
```
private static final byte[] PSUBSCRIBE
```

PUNSUBSCRIBE

private static final byte[] PUNSUBSCRIBE

AUTH

protected static final java.lang.String AUTH

See Also:: Constant Field Values

AUTH_BYTES

protected static final byte[] AUTH_BYTES

Constructor Detail

RedisClientBase

protected RedisClientBase(java.lang.String host,
                          int port,
                          java.util.concurrent.ExecutorService executorService)
                   throws RedisException

Throws:: RedisException

Method Detail

connect

private boolean connect()
                 throws RedisException

Throws:: RedisException

parseInfo
```
private void parseInfo()
```

parseVersion

public static int parseVersion(java.lang.String value)

pipeline

public com.google.common.util.concurrent.ListenableFuture<? extends Reply> pipeline(java.lang.String name,
                                                                                    Command command)
                                                                             throws RedisException

Throws:: RedisException

execute

public Reply execute(java.lang.String name,
                     Command command)
              throws RedisException

Throws:: RedisException

getRedisProtocol

public RedisProtocol getRedisProtocol()

close

public void close()
           throws java.io.IOException

Throws:: java.io.IOException

multi
```
public StatusReply multi()
```

discard
```
public StatusReply discard()
```

exec

public java.util.concurrent.Future<java.lang.Boolean> exec()

addListener
```
public void addListener(ReplyListener replyListener)
```
Add a reply listener to this client for subscriptions.

removeListener

public boolean removeListener(ReplyListener replyListener)

Remove a reply listener from this client.

subscribe
```
public void subscribe(java.lang.Object... subscriptions)
```
Subscribes the client to the specified channels.

Parameters:

subscriptions -

psubscribe
```
public void psubscribe(java.lang.Object... subscriptions)
```
Subscribes the client to the specified patterns.

Parameters:

subscriptions -

unsubscribe
```
public void unsubscribe(java.lang.Object... subscriptions)
```
Unsubscribes the client to the specified channels.

Parameters:

subscriptions -

punsubscribe
```
public void punsubscribe(java.lang.Object... subscriptions)
```
Unsubscribes the client to the specified patterns.

Parameters:

subscriptions -

subscribe
```
private void subscribe()
```

auth
```
public StatusReply auth(java.lang.Object password0)
                 throws RedisException
```
Authenticate to the server Connection

Parameters:

password0 -

Returns:

StatusReply

Throws:

RedisException

Class RedisClientBase

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

BYTES

WEIGHTS

WITHSCORES

ALPHA

LIMIT

DESC

BY

STORE

GET

host

port

es

redisProtocol

versionMatcher

pipelined

version

parseAttempted

txReplies

retrying

MULTI

EXEC

DISCARD

tx

replyListeners

subscribed

MESSAGE

PMESSAGE

SUBSCRIBE

UNSUBSCRIBE

PSUBSCRIBE

PUNSUBSCRIBE

AUTH

AUTH_BYTES

Constructor Detail

RedisClientBase

Method Detail

connect

parseInfo

parseVersion

pipeline

execute

getRedisProtocol

close

multi

discard

exec

addListener

removeListener

subscribe

psubscribe

unsubscribe

punsubscribe

subscribe

auth