org.jredis.ri.alphazero.protocol

Class ConcurrentSyncProtocol

java.lang.Object

org.jredis.ri.alphazero.protocol.ProtocolBase

org.jredis.ri.alphazero.protocol.SyncProtocol

org.jredis.ri.alphazero.protocol.ConcurrentSyncProtocol

All Implemented Interfaces:

Protocol

public class ConcurrentSyncProtocol
extends SyncProtocol

This basically extends SyncProtocol so that the response buffers are not shared, so that it can be used in multi-threaded environments.

Since:

alpha.0

Version:

alpha.0, Apr 23, 2009

Author:

Joubin (alphazero@sensesay.net)

Nested Class Summary

Nested classes/interfaces inherited from class org.jredis.ri.alphazero.protocol.SyncProtocol

SyncProtocol.SyncBulkResponse, SyncProtocol.SyncLineResponse, SyncProtocol.SyncMultiBulkResponse, SyncProtocol.SyncMultiLineResponseBase, SyncProtocol.SyncResponseBase, SyncProtocol.ValueType

Nested classes/interfaces inherited from class org.jredis.ri.alphazero.protocol.ProtocolBase

ProtocolBase.StreamBufferRequest

Nested classes/interfaces inherited from interface org.jredis.protocol.Protocol

Protocol.Factory

Field Summary

Fields inherited from class org.jredis.ri.alphazero.protocol.SyncProtocol

INPUT_STREAM_BUFFER_SIZE, PREFERRED_LINE_BUFFER_SIZE, PREFERRED_REQUEST_BUFFER_SIZE

Fields inherited from class org.jredis.ri.alphazero.protocol.ProtocolBase

ASCII_ZERO, COUNT_BYTE, CRLF, CRLF_LEN, DELIMETER_LEN, ERR_BYTE, NUM_BYTE, OK_BYTE, SIZE_BYTE, SPACE

Constructor Summary

Constructors

Constructor and Description
ConcurrentSyncProtocol()

Method Summary

Modifier and Type	Method and Description
protected Response	createBooleanResponse(Command cmd)
protected Response	createBulkResponse(Command cmd)
protected Response	createMultiBulkResponse(Command cmd)
protected Response	createNumberResponse(Command cmd)
protected Response	createStatusResponse(Command cmd)
protected Response	createStringResponse(Command cmd)

Methods inherited from class org.jredis.ri.alphazero.protocol.SyncProtocol

createRequest, createRequestBufffer

Methods inherited from class org.jredis.ri.alphazero.protocol.ProtocolBase

createRequest, createRequestBuffer, createResponse, isCompatibleWithVersion

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcurrentSyncProtocol

public ConcurrentSyncProtocol()

Method Detail

createStatusResponse

protected Response createStatusResponse(Command cmd)

Overrides:

createStatusResponse in class SyncProtocol

createBooleanResponse

protected Response createBooleanResponse(Command cmd)

Overrides:

createBooleanResponse in class SyncProtocol

createStringResponse

protected Response createStringResponse(Command cmd)

Overrides:

createStringResponse in class SyncProtocol

createNumberResponse

protected Response createNumberResponse(Command cmd)

Overrides:

createNumberResponse in class SyncProtocol

createBulkResponse

protected Response createBulkResponse(Command cmd)

Overrides:

createBulkResponse in class SyncProtocol

createMultiBulkResponse

protected Response createMultiBulkResponse(Command cmd)

Overrides:

createMultiBulkResponse in class SyncProtocol