Class Command

    • Field Detail

      • added

        private boolean added
      • key

        protected java.lang.String key
      • keyBytes

        protected byte[] keyBytes
      • result

        protected java.lang.Object result
      • latch

        protected java.util.concurrent.CountDownLatch latch
      • exception

        protected java.lang.Exception exception
      • cancel

        protected volatile boolean cancel
      • mergeCount

        protected int mergeCount
      • copiedMergeCount

        private int copiedMergeCount
      • noreply

        protected boolean noreply
      • writeFuture

        protected FutureImpl<java.lang.Boolean> writeFuture
    • Constructor Detail

      • Command

        public Command()
      • Command

        public Command​(java.lang.String key,
                       byte[] keyBytes,
                       java.util.concurrent.CountDownLatch latch)
      • Command

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

        public Command​(CommandType cmdType,
                       java.util.concurrent.CountDownLatch latch)
      • Command

        public Command​(java.lang.String key,
                       CommandType commandType,
                       java.util.concurrent.CountDownLatch latch)
    • Method Detail

      • isAdded

        public boolean isAdded()
      • setAdded

        public void setAdded​(boolean added)
      • getMessage

        public final java.lang.Object getMessage()
        Specified by:
        getMessage in interface WriteMessage
      • getKeyBytes

        public final byte[] getKeyBytes()
      • setKeyBytes

        public final void setKeyBytes​(byte[] keyBytes)
      • setCommandType

        public void setCommandType​(CommandType commandType)
      • getMergeCount

        public int getMergeCount()
      • getTranscoder

        public Transcoder getTranscoder()
      • setTranscoder

        public void setTranscoder​(Transcoder transcoder)
      • setMergeCount

        public void setMergeCount​(int mergetCount)
      • getCopiedMergeCount

        public int getCopiedMergeCount()
      • setIoBuffer

        public final void setIoBuffer​(IoBuffer ioBuffer)
      • getException

        public java.lang.Exception getException()
      • setException

        public void setException​(java.lang.Exception throwable)
      • getKey

        public final java.lang.String getKey()
      • setKey

        public final void setKey​(java.lang.String key)
      • getResult

        public final java.lang.Object getResult()
      • setResult

        public final void setResult​(java.lang.Object result)
      • getIoBuffer

        public final IoBuffer getIoBuffer()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • isCancel

        public boolean isCancel()
      • cancel

        public final void cancel()
      • getLatch

        public final java.util.concurrent.CountDownLatch getLatch()
      • countDownLatch

        public final void countDownLatch()
      • getCommandType

        public final CommandType getCommandType()
      • setLatch

        public final void setLatch​(java.util.concurrent.CountDownLatch latch)
      • encode

        public abstract void encode()
      • decode

        public abstract boolean decode​(MemcachedTCPSession session,
                                       java.nio.ByteBuffer buffer)
      • decodeError

        protected final void decodeError​(java.lang.String msg,
                                         java.lang.Throwable e)
      • decodeError

        protected final void decodeError()
      • decodeError

        protected final boolean decodeError​(java.lang.String line)
      • decodeError

        protected final boolean decodeError​(Session session,
                                            java.nio.ByteBuffer buffer)
      • getErrorMsg

        private java.lang.String getErrorMsg​(java.lang.String line,
                                             java.lang.String defaultMsg)
      • isNoreply

        public final boolean isNoreply()
      • setNoreply

        public final void setNoreply​(boolean noreply)
      • setWriteFuture

        public final void setWriteFuture​(FutureImpl<java.lang.Boolean> writeFuture)