Class TextGetCommand

java.lang.Object

net.rubyeye.xmemcached.command.Command

net.rubyeye.xmemcached.command.text.TextGetCommand

All Implemented Interfaces:

WriteMessage, AssocCommandAware, MapReturnValueAware, MergeCommandsAware

Direct Known Subclasses:

KestrelGetCommand, TextGetMultiCommand, TextGetOneCommand

public abstract class TextGetCommand
extends Command
implements MergeCommandsAware, AssocCommandAware, MapReturnValueAware

Abstract get command for text protocol

Author:

dennis

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	TextGetCommand.ParseStatus

Field Summary

Fields

Modifier and Type	Field	Description
protected List<Command>	assocCommands	When MemcachedClient merge get commands,those commans which have the same key will be merged into one get command.The result command's assocCommands contains all these commands with the same key.
protected Map<Object,Command>	mergeCommands
protected Map<String, CachedData>	returnValues
protected boolean	wasFirst

Fields inherited from class Command

cancel, commandType, exception, ioBuffer, key, keyBytes, latch, mergeCount, noreply, REQUEST_MAGIC_NUMBER, RESPONSE_MAGIC_NUMBER, result, status, transcoder, writeFuture

Constructor Summary

Constructors

Constructor	Description
TextGetCommand(String key, byte[] keyBytes, CommandType cmdType, CountDownLatch latch)

Method Summary

Modifier and Type	Method	Description
final boolean	decode(MemcachedTCPSession session, ByteBuffer buffer)
abstract void	dispatch()
void	encode()
final List<Command>	getAssocCommands()
final Map<Object,Command>	getMergeCommands()
TextGetCommand.ParseStatus	getParseStatus()
final Map<String, CachedData>	getReturnValues()
final void	setAssocCommands(List<Command> assocCommands)
final void	setMergeCommands(Map<Object,Command> mergeCommands)
void	setParseStatus(TextGetCommand.ParseStatus parseStatus)
final void	setReturnValues(Map<String, CachedData> returnValues)

Methods inherited from class Command

cancel, countDownLatch, decodeError, decodeError, decodeError, decodeError, getCommandType, getCopiedMergeCount, getException, getIoBuffer, getKey, getKeyBytes, getLatch, getMergeCount, getMessage, getResult, getStatus, getTranscoder, getWriteBuffer, getWriteFuture, isAdded, isCancel, isNoreply, isWriting, setAdded, setCommandType, setException, setIoBuffer, setKey, setKeyBytes, setLatch, setMergeCount, setNoreply, setResult, setStatus, setTranscoder, setWriteBuffer, setWriteFuture, toString, writing

Methods inherited from class Object

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

Field Details

returnValues

protected Map<String, CachedData> returnValues

assocCommands

protected List<Command> assocCommands

When MemcachedClient merge get commands,those commans which have the same key will be merged into one get command.The result command's assocCommands contains all these commands with the same key.

mergeCommands

protected Map<Object,Command> mergeCommands

wasFirst

protected boolean wasFirst

Constructor Details

TextGetCommand

public TextGetCommand(String key,
 byte[] keyBytes,
 CommandType cmdType,
 CountDownLatch latch)

Method Details

getMergeCommands

public final Map<Object,Command> getMergeCommands()

Specified by:

getMergeCommands in interface MergeCommandsAware

setMergeCommands

public final void setMergeCommands(Map<Object,Command> mergeCommands)

Specified by:

setMergeCommands in interface MergeCommandsAware

getAssocCommands

public final List<Command> getAssocCommands()

Specified by:

getAssocCommands in interface AssocCommandAware

setAssocCommands

public final void setAssocCommands(List<Command> assocCommands)

Specified by:

setAssocCommands in interface AssocCommandAware

getParseStatus

public TextGetCommand.ParseStatus getParseStatus()

setParseStatus

public void setParseStatus(TextGetCommand.ParseStatus parseStatus)

decode

public final boolean decode(MemcachedTCPSession session,
 ByteBuffer buffer)

Specified by:

decode in class Command

getReturnValues

public final Map<String, CachedData> getReturnValues()

Specified by:

getReturnValues in interface MapReturnValueAware

setReturnValues

public final void setReturnValues(Map<String, CachedData> returnValues)

dispatch

public abstract void dispatch()

encode

public void encode()

Specified by:

encode in class Command