RedisClientBase (redis 0.7 API)

java.lang.Object
- redis.client.RedisClientBase

Direct Known Subclasses:

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

Field Summary

Fields
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`

Constructor Summary

Constructors
Modifier Constructor and Description

protected RedisClientBase(String host, int port, ExecutorService executorService)

Constructors
Modifier	Constructor and Description
`protected`	`RedisClientBase(String host, int port, 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(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.

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

Field Detail

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
```

redisProtocol
```
protected RedisProtocol redisProtocol
```

pipelined
```
protected AtomicInteger pipelined
```

version
```
protected int version
```

AUTH
```
protected static final String AUTH
```
See Also:

Constant Field Values

AUTH_BYTES

protected static final byte[] AUTH_BYTES

Constructor Detail

RedisClientBase

protected RedisClientBase(String host,
                          int port,
                          ExecutorService executorService)
                   throws RedisException

Throws:: RedisException

Method Detail

parseVersion

public static int parseVersion(String value)

pipeline

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

Throws:: RedisException

execute

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

Throws:: RedisException

getRedisProtocol

public RedisProtocol getRedisProtocol()

close

public void close()
           throws IOException

Throws:: IOException

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

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

exec
```
public Future<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(Object... subscriptions)
```
Subscribes the client to the specified channels.

Parameters:

subscriptions -

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

Parameters:

subscriptions -

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

Parameters:

subscriptions -

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

Parameters:

subscriptions -

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

Parameters:

password0 -

Returns:

StatusReply

Throws:

RedisException

Class RedisClientBase

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

WEIGHTS

WITHSCORES

ALPHA

LIMIT

DESC

BY

STORE

GET

redisProtocol

pipelined

version

AUTH

AUTH_BYTES

Constructor Detail

RedisClientBase

Method Detail

parseVersion

pipeline

execute

getRedisProtocol

close

multi

discard

exec

addListener

removeListener

subscribe

psubscribe

unsubscribe

punsubscribe

auth