Class RequestMessage


  • public class RequestMessage
    extends BaseMessage
    A tap request message that is used to start tap streams, perform sasl authentication, and maintain the health of tap streams.
    • Field Detail

      • hasBackfill

        private boolean hasBackfill
      • hasVBucketList

        private boolean hasVBucketList
      • hasVBucketCheckpoints

        private boolean hasVBucketCheckpoints
      • hasFlags

        private boolean hasFlags
      • vblist

        private short[] vblist
      • name

        private java.lang.String name
      • backfilldate

        private long backfilldate
      • vBucketCheckpoints

        private java.util.Map<java.lang.Short,​java.lang.Long> vBucketCheckpoints
    • Constructor Detail

      • RequestMessage

        public RequestMessage()
        Create a tap request message. These messages are used to start tap streams.
    • Method Detail

      • setFlags

        public void setFlags​(TapRequestFlag f)
        Sets the flags for the tap stream. These flags decide what kind of tap stream will be received.
        Parameters:
        f - The flags to use for this tap stream.
      • getFlags

        public java.util.List<TapRequestFlag> getFlags()
        Returns the flags for this message.
        Returns:
        An int value of flags set for this tap message.
      • setBackfill

        public void setBackfill​(long date)
        Stream all keys inserted into the server after a given date.
        Parameters:
        date - - The date to stream keys from. Null to stream all keys.
      • setVbucketlist

        public void setVbucketlist​(short[] vbs)
        Sets a list of vbuckets to stream keys from.
        Parameters:
        vbs - - A list of vbuckets.
      • setvBucketCheckpoints

        public void setvBucketCheckpoints​(java.util.Map<java.lang.Short,​java.lang.Long> vbchkpnts)
        Sets a map of vbucket checkpoints.
        Parameters:
        vbchkpnts - - A map of vbucket checkpoint identifiers
      • setName

        public void setName​(java.lang.String n)
        Sets a name for this tap stream. If the tap stream fails this name can be used to try to restart the tap stream from where it last left off.
        Parameters:
        n - The name for the tap stream.
      • getBytes

        public java.nio.ByteBuffer getBytes()
        Encodes the message into binary.
        Specified by:
        getBytes in class BaseMessage
        Returns:
        The ByteBuffer representation of the message.