net.rubyeye.xmemcached.command.text
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

static class

TextGetCommand.ParseStatus

Field Summary

protected java.util.Map<java.lang.String,CachedData>	returnValues
protected boolean	wasFirst

Fields inherited from class net.rubyeye.xmemcached.command.Command

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

Constructor Summary

TextGetCommand(java.lang.String key, byte[] keyBytes, CommandType cmdType, java.util.concurrent.CountDownLatch latch)

Method Summary

boolean	decode(MemcachedTCPSession session, java.nio.ByteBuffer buffer)
abstract void	dispatch()
void	encode()
java.util.List<Command>	getAssocCommands()
java.util.Map<java.lang.Object,Command>	getMergeCommands()
TextGetCommand.ParseStatus	getParseStatus()
java.util.Map<java.lang.String,CachedData>	getReturnValues()
void	setAssocCommands(java.util.List<Command> assocCommands)
void	setMergeCommands(java.util.Map<java.lang.Object,Command> mergeCommands)
void	setParseStatus(TextGetCommand.ParseStatus parseStatus)
void	setReturnValues(java.util.Map<java.lang.String,CachedData> returnValues)

Methods inherited from class net.rubyeye.xmemcached.command.Command

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

Methods inherited from class java.lang.Object

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

Field Detail

returnValues

protected java.util.Map<java.lang.String,CachedData> returnValues

wasFirst

protected boolean wasFirst

Constructor Detail

TextGetCommand

public TextGetCommand(java.lang.String key,
                      byte[] keyBytes,
                      CommandType cmdType,
                      java.util.concurrent.CountDownLatch latch)

Method Detail

getMergeCommands

public final java.util.Map<java.lang.Object,Command> getMergeCommands()

Specified by:

getMergeCommands in interface MergeCommandsAware

setMergeCommands

public final void setMergeCommands(java.util.Map<java.lang.Object,Command> mergeCommands)

Specified by:

setMergeCommands in interface MergeCommandsAware

getAssocCommands

public final java.util.List<Command> getAssocCommands()

Specified by:

getAssocCommands in interface AssocCommandAware

setAssocCommands

public final void setAssocCommands(java.util.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,
                            java.nio.ByteBuffer buffer)

Specified by:

decode in class Command

getReturnValues

public final java.util.Map<java.lang.String,CachedData> getReturnValues()

Specified by:

getReturnValues in interface MapReturnValueAware

setReturnValues

public final void setReturnValues(java.util.Map<java.lang.String,CachedData> returnValues)

dispatch

public abstract void dispatch()

encode

public void encode()

Specified by:

encode in class Command