Package net.spy.memcached.tapmessage
Class ResponseMessage
java.lang.Object
net.spy.memcached.compat.SpyObject
net.spy.memcached.tapmessage.BaseMessage
net.spy.memcached.tapmessage.ResponseMessage
A representation of a tap stream message sent from a tap stream server.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final long
private static final int
private final short
private final List
<TapResponseFlag> private static final int
private static final int
private static final int
private int
private final int
private final byte[]
private static final int
private final byte
private static final int
private final byte
private static final int
private final byte
private static final int
private final byte[]
private final byte
private static final int
private final byte[]
private final int
Fields inherited from class net.spy.memcached.tapmessage.BaseMessage
cas, datatype, extralength, HEADER_LENGTH, keylength, magic, opaque, opcode, totalbody, vbucket
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate Object
Attempt to get the object represented by the given serialized bytes.getBytes()
Creates a ByteBuffer representation of the message.long
Gets the checkpoint of the vbucket.long
Gets the value of the engine private field.getFlags()
Gets the value of the flags field.long
Gets the value of the item expiry field.int
Gets the value of the items flag field.getKey()
Gets the value of the key field.protected int
Gets the value of the reserved1 field.protected int
Gets the value of the reserved2 field.protected int
Gets the value of the reserved3 field.byte[]
getRevID()
Gets the value of the revid field.int
getTTL()
Gets the value of the time to live field.byte[]
getValue()
Gets the value of the value field.int
Gets the state of the vbucket.toString()
Methods inherited from class net.spy.memcached.tapmessage.BaseMessage
decodeInt, decodeIntHostOrder, decodeLong, decodeShort, getCas, getDatatype, getExtralength, getKeylength, getMagic, getMessageLength, getOpaque, getOpcode, getTotalbody, getVbucket, setCas, setDatatype, setExtralength, setMagic, setOpaque, setOpcode, setTotalbody, setVbucket
-
Field Details
-
ENGINE_PRIVATE_OFFSET
private static final int ENGINE_PRIVATE_OFFSET- See Also:
-
FLAGS_OFFSET
private static final int FLAGS_OFFSET- See Also:
-
TTL_OFFSET
private static final int TTL_OFFSET- See Also:
-
RESERVED1_OFFSET
private static final int RESERVED1_OFFSET- See Also:
-
RESERVED2_OFFSET
private static final int RESERVED2_OFFSET- See Also:
-
RESERVED3_OFFSET
private static final int RESERVED3_OFFSET- See Also:
-
ITEM_FLAGS_OFFSET
private static final int ITEM_FLAGS_OFFSET- See Also:
-
ITEM_EXPIRY_OFFSET
private static final int ITEM_EXPIRY_OFFSET- See Also:
-
KEY_OFFSET
private static final int KEY_OFFSET- See Also:
-
engineprivate
private final short engineprivate -
flags
-
ttl
private final byte ttl -
reserved1
private final byte reserved1 -
reserved2
private final byte reserved2 -
reserved3
private final byte reserved3 -
itemflags
private final int itemflags -
itemexpiry
private int itemexpiry -
vbucketstate
private final int vbucketstate -
checkpoint
private final long checkpoint -
key
private final byte[] key -
value
private final byte[] value -
revid
private final byte[] revid
-
-
Constructor Details
-
ResponseMessage
public ResponseMessage(byte[] b) Creates a ResponseMessage from binary data.- Parameters:
b
- The binary data sent from the tap stream server.
-
-
Method Details
-
getEnginePrivate
public long getEnginePrivate()Gets the value of the engine private field. Not returned in a no-op message.- Returns:
- The engine private data.
-
getFlags
Gets the value of the flags field. Not returned in a no-op message.- Returns:
- The flags data.
-
getTTL
public int getTTL()Gets the value of the time to live field. Not returned in a no-op message.- Returns:
- The time to live value;
-
getReserved1
protected int getReserved1()Gets the value of the reserved1 field. Not returned in a no-op message.- Returns:
- The reserved1 data.
-
getReserved2
protected int getReserved2()Gets the value of the reserved2 field. Not returned in a no-op message.- Returns:
- The reserved2 data.
-
getReserved3
protected int getReserved3()Gets the value of the reserved3 field. Not returned in a no-op message.- Returns:
- The reserved3 data.
-
getVBucketState
public int getVBucketState()Gets the state of the vbucket. Only returned with a tap vbucket state message.- Returns:
- the vbucket state
-
getCheckpoint
public long getCheckpoint()Gets the checkpoint of the vbucket. Only returned with a start/end checkpoint message.- Returns:
- the checkpoint
-
getItemFlags
public int getItemFlags()Gets the value of the items flag field. Only returned with a tap mutation message.- Returns:
- The items flag data.
-
getItemExpiry
public long getItemExpiry()Gets the value of the item expiry field. Only returned with a tap mutation message.- Returns:
- The item expiry data.
-
getKey
Gets the value of the key field. Only returned with a tap mutation or tap delete message.- Returns:
- The key data.
-
getValue
public byte[] getValue()Gets the value of the value field. Only returned with a tap mutation message.- Returns:
- The value data.
-
getRevID
public byte[] getRevID()Gets the value of the revid field. Only returned with a tap mutation message.- Returns:
- The revid of the document.
-
getBytes
Description copied from class:BaseMessage
Creates a ByteBuffer representation of the message.- Specified by:
getBytes
in classBaseMessage
- Returns:
- The ByteBuffer representation of the message.
-
toString
-
deserialize
Attempt to get the object represented by the given serialized bytes.
-