redis.clients.jedis

Class Connection

java.lang.Object

redis.clients.jedis.Connection

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Direct Known Subclasses:

BinaryClient

public class Connection
extends java.lang.Object
implements java.io.Closeable

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	broken
private int	connectionTimeout
private java.lang.String	host
private RedisInputStream	inputStream
private RedisOutputStream	outputStream
private int	pipelinedCommands
private int	port
private java.net.Socket	socket
private int	soTimeout

Constructor Summary

Constructors

Constructor and Description
Connection()
Connection(java.lang.String host)
Connection(java.lang.String host, int port)

Method Summary

Modifier and Type	Method and Description
void	close()
void	connect()
void	disconnect()
protected void	flush()
java.util.List<java.lang.Object>	getAll()
java.util.List<java.lang.Object>	getAll(int except)
byte[]	getBinaryBulkReply()
java.util.List<byte[]>	getBinaryMultiBulkReply()
java.lang.String	getBulkReply()
int	getConnectionTimeout()
java.lang.String	getHost()
java.util.List<java.lang.Long>	getIntegerMultiBulkReply()
java.lang.Long	getIntegerReply()
java.util.List<java.lang.String>	getMultiBulkReply()
java.util.List<java.lang.Object>	getObjectMultiBulkReply()
java.lang.Object	getOne()
int	getPort()
java.util.List<java.lang.Object>	getRawObjectMultiBulkReply()
java.net.Socket	getSocket()
int	getSoTimeout()
java.lang.String	getStatusCodeReply()
boolean	isBroken()
boolean	isConnected()
protected java.lang.Object	readProtocolWithCheckingBroken()
void	resetPipelinedCount()
void	rollbackTimeout()
protected Connection	sendCommand(ProtocolCommand cmd)
protected Connection	sendCommand(ProtocolCommand cmd, byte[]... args)
protected Connection	sendCommand(ProtocolCommand cmd, java.lang.String... args)
void	setConnectionTimeout(int connectionTimeout)
void	setHost(java.lang.String host)
void	setPort(int port)
void	setSoTimeout(int soTimeout)
void	setTimeoutInfinite()

Methods inherited from class java.lang.Object

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

Field Detail

host

private java.lang.String host

port

private int port

socket

private java.net.Socket socket

outputStream

private RedisOutputStream outputStream

inputStream

private RedisInputStream inputStream

pipelinedCommands

private int pipelinedCommands

connectionTimeout

private int connectionTimeout

soTimeout

private int soTimeout

broken

private boolean broken

Constructor Detail

Connection

public Connection()

Connection

public Connection(java.lang.String host)

Connection

public Connection(java.lang.String host,
                  int port)

Method Detail

getSocket

public java.net.Socket getSocket()

getConnectionTimeout

public int getConnectionTimeout()

getSoTimeout

public int getSoTimeout()

setConnectionTimeout

public void setConnectionTimeout(int connectionTimeout)

setSoTimeout

public void setSoTimeout(int soTimeout)

setTimeoutInfinite

public void setTimeoutInfinite()

rollbackTimeout

public void rollbackTimeout()

sendCommand

protected Connection sendCommand(ProtocolCommand cmd,
                                 java.lang.String... args)

sendCommand

protected Connection sendCommand(ProtocolCommand cmd,
                                 byte[]... args)

sendCommand

protected Connection sendCommand(ProtocolCommand cmd)

getHost

public java.lang.String getHost()

setHost

public void setHost(java.lang.String host)

getPort

public int getPort()

setPort

public void setPort(int port)

connect

public void connect()

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

disconnect

public void disconnect()

isConnected

public boolean isConnected()

getStatusCodeReply

public java.lang.String getStatusCodeReply()

getBulkReply

public java.lang.String getBulkReply()

getBinaryBulkReply

public byte[] getBinaryBulkReply()

getIntegerReply

public java.lang.Long getIntegerReply()

getMultiBulkReply

public java.util.List<java.lang.String> getMultiBulkReply()

getBinaryMultiBulkReply

public java.util.List<byte[]> getBinaryMultiBulkReply()

resetPipelinedCount

public void resetPipelinedCount()

getRawObjectMultiBulkReply

public java.util.List<java.lang.Object> getRawObjectMultiBulkReply()

getObjectMultiBulkReply

public java.util.List<java.lang.Object> getObjectMultiBulkReply()

getIntegerMultiBulkReply

public java.util.List<java.lang.Long> getIntegerMultiBulkReply()

getAll

public java.util.List<java.lang.Object> getAll()

getAll

public java.util.List<java.lang.Object> getAll(int except)

getOne

public java.lang.Object getOne()

isBroken

public boolean isBroken()

flush

protected void flush()

readProtocolWithCheckingBroken

protected java.lang.Object readProtocolWithCheckingBroken()