Class TextIncrDecrCommand
- java.lang.Object
-
- net.rubyeye.xmemcached.command.Command
-
- net.rubyeye.xmemcached.command.text.TextIncrDecrCommand
-
- All Implemented Interfaces:
WriteMessage
public class TextIncrDecrCommand extends Command
Incr/Decr command for text protocol
-
-
Field Summary
Fields Modifier and Type Field Description private long
delta
private long
initial
-
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
Constructors Constructor Description TextIncrDecrCommand(java.lang.String key, byte[] keyBytes, CommandType cmdType, java.util.concurrent.CountDownLatch latch, long delta, long initial, boolean noreply)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
decode(MemcachedTCPSession session, java.nio.ByteBuffer buffer)
void
encode()
long
getDelta()
void
setDelta(int delta)
-
Methods inherited from class net.rubyeye.xmemcached.command.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
-
-
-
-
Constructor Detail
-
TextIncrDecrCommand
public TextIncrDecrCommand(java.lang.String key, byte[] keyBytes, CommandType cmdType, java.util.concurrent.CountDownLatch latch, long delta, long initial, boolean noreply)
-
-
Method Detail
-
getDelta
public final long getDelta()
-
setDelta
public final void setDelta(int delta)
-
decode
public final boolean decode(MemcachedTCPSession session, java.nio.ByteBuffer buffer)
-
-