ClientMessage (Hazelcast Root 3.12.12 API)

java.lang.Object
- com.hazelcast.client.impl.protocol.util.MessageFlyweight
- - com.hazelcast.client.impl.protocol.ClientMessage

All Implemented Interfaces:: OutboundFrame

public class ClientMessage
extends MessageFlyweight
implements OutboundFrame

Client Message is the carrier framed data as defined below.

Any request parameter, response or event data will be carried in the payload.

 0                   1                   2                   3
 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 |R|                      Frame Length                           |
 +-------------+---------------+---------------------------------+
 |  Version    |B|E|  Flags    |               Type              |
 +-------------+---------------+---------------------------------+
 |                                                               |
 +                       CorrelationId                           +
 |                                                               |
 +---------------------------------------------------------------+
 |                        PartitionId                            |
 +-----------------------------+---------------------------------+
 |        Data Offset          |                                 |
 +-----------------------------+                                 |
 |                      Message Payload Data                    ...
 |                                                              ...

Field Summary

Fields
Modifier and Type	Field and Description
`static short`	`BEGIN_AND_END_FLAGS` Begin and End Flags
`static short`	`BEGIN_FLAG` Begin Flag
`static short`	`END_FLAG` End Flag
`static int`	`HEADER_SIZE` ClientMessage Fixed Header size in bytes
`static short`	`LISTENER_EVENT_FLAG` Listener Event Flag
`static short`	`VERSION` Current protocol version

Fields inherited from class com.hazelcast.client.impl.protocol.util.MessageFlyweight
buffer

Constructor Summary

Constructors
Modifier Constructor and Description

protected ClientMessage()

Constructors
Modifier	Constructor and Description
`protected`	`ClientMessage()`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`boolean`	`acquiresResource()`
`ClientMessage`	`addFlag(short flags)` Sets the flags field value.
`ClientMessage`	`copy()`
`static ClientMessage`	`create()`
`static ClientMessage`	`createForDecode(ClientProtocolBuffer buffer, int offset)`
`static ClientMessage`	`createForEncode(ClientProtocolBuffer buffer, int offset)`
`static ClientMessage`	`createForEncode(int initialCapacity)`
`boolean`	`equals(Object o)`
`Connection`	`getConnection()`
`long`	`getCorrelationId()` Returns the correlation ID field.
`int`	`getDataOffset()` Returns the setDataOffset field.
`short`	`getFlags()` Returns the flags field value.
`int`	`getFrameLength()` Returns the frame length field.
`int`	`getMessageType()` Returns the message type field.
`String`	`getOperationName()`
`int`	`getPartitionId()` Returns the partition ID field.
`short`	`getVersion()` Returns the version field value.
`int`	`hashCode()`
`boolean`	`isComplete()` Checks the frame size and total data size to validate the message size.
`boolean`	`isFlagSet(short flag)`
`boolean`	`isRetryable()`
`boolean`	`isUrgent()` Checks if this Frame is urgent.
`boolean`	`readFrom(ByteBuffer src)`
`void`	`setAcquiresResource(boolean acquiresResource)`
`void`	`setConnection(Connection connection)`
`ClientMessage`	`setCorrelationId(long correlationId)` Sets the correlation ID field.
`ClientMessage`	`setDataOffset(int dataOffset)` Sets the dataOffset field.
`ClientMessage`	`setFrameLength(int length)` Sets the frame length field.
`ClientMessage`	`setMessageType(int type)` Sets the message type field.
`void`	`setOperationName(String operationName)`
`ClientMessage`	`setPartitionId(int partitionId)` Sets the partition ID field.
`void`	`setRetryable(boolean isRetryable)`
`ClientMessage`	`setVersion(short version)` Sets the version field value.
`String`	`toString()`
`ClientMessage`	`updateFrameLength()`
`protected void`	`wrapForDecode(ClientProtocolBuffer buffer, int offset)`
`protected void`	`wrapForEncode(ClientProtocolBuffer buffer, int offset)`
`boolean`	`writeTo(ByteBuffer dst)`

Methods inherited from class com.hazelcast.client.impl.protocol.util.MessageFlyweight
buffer, getBoolean, getByte, getByteArray, getData, getDataList, getInt, getLong, getStringUtf8, index, index, int32Get, int32Set, int64Get, int64Set, set, set, set, set, set, set, set, set, set, uint16Get, uint16Put, uint32Get, uint32Put, uint8Get, uint8Put, wrap

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

- Field Detail
  - VERSION
```
public static final short VERSION
```
    Current protocol version
    
    See Also:
    
    Constant Field Values
  - BEGIN_FLAG
```
public static final short BEGIN_FLAG
```
    Begin Flag
    
    See Also:
    
    Constant Field Values
  - END_FLAG
```
public static final short END_FLAG
```
    End Flag
    
    See Also:
    
    Constant Field Values
  - BEGIN_AND_END_FLAGS
```
public static final short BEGIN_AND_END_FLAGS
```
    Begin and End Flags
    
    See Also:
    
    Constant Field Values
  - LISTENER_EVENT_FLAG
```
public static final short LISTENER_EVENT_FLAG
```
    Listener Event Flag
    
    See Also:
    
    Constant Field Values
  - HEADER_SIZE
```
public static final int HEADER_SIZE
```
    ClientMessage Fixed Header size in bytes
- Constructor Detail
  - ClientMessage
```
protected ClientMessage()
```
- Method Detail
  - getConnection
```
public Connection getConnection()
```
  - setConnection
```
public void setConnection(Connection connection)
```
  - wrapForEncode
```
protected void wrapForEncode(ClientProtocolBuffer buffer,
                             int offset)
```
  - wrapForDecode
```
protected void wrapForDecode(ClientProtocolBuffer buffer,
                             int offset)
```
  - getVersion
```
public short getVersion()
```
    Returns the version field value.
    
    Returns:
    
    The version field value.
  - setVersion
```
public ClientMessage setVersion(short version)
```
    Sets the version field value.
    
    Parameters:
    
    version - The value to set in the version field.
    
    Returns:
    
    The ClientMessage with the new version field value.
  - isFlagSet
```
public boolean isFlagSet(short flag)
```
    Parameters:
    
    flag - Check this flag to see if it is set.
    
    Returns:
    
    true if the given flag is set, false otherwise.
  - getFlags
```
public short getFlags()
```
    Returns the flags field value.
    
    Returns:
    
    The flags field value.
  - addFlag
```
public ClientMessage addFlag(short flags)
```
    Sets the flags field value.
    
    Parameters:
    
    flags - The value to set in the flags field.
    
    Returns:
    
    The ClientMessage with the new flags field value.
  - getMessageType
```
public int getMessageType()
```
    Returns the message type field.
    
    Returns:
    
    The message type field value.
  - setMessageType
```
public ClientMessage setMessageType(int type)
```
    Sets the message type field.
    
    Parameters:
    
    type - The value to set in the message type field.
    
    Returns:
    
    The ClientMessage with the new message type field value.
  - getFrameLength
```
public int getFrameLength()
```
    Returns the frame length field.
    
    Specified by:
    
    getFrameLength in interface OutboundFrame
    
    Returns:
    
    The frame length field.
  - setFrameLength
```
public ClientMessage setFrameLength(int length)
```
    Sets the frame length field.
    
    Parameters:
    
    length - The value to set in the frame length field.
    
    Returns:
    
    The ClientMessage with the new frame length field value.
  - getCorrelationId
```
public long getCorrelationId()
```
    Returns the correlation ID field.
    
    Returns:
    
    The correlation ID field.
  - setCorrelationId
```
public ClientMessage setCorrelationId(long correlationId)
```
    Sets the correlation ID field.
    
    Parameters:
    
    correlationId - The value to set in the correlation ID field.
    
    Returns:
    
    The ClientMessage with the new correlation ID field value.
  - getPartitionId
```
public int getPartitionId()
```
    Returns the partition ID field.
    
    Returns:
    
    The partition ID field.
  - setPartitionId
```
public ClientMessage setPartitionId(int partitionId)
```
    Sets the partition ID field.
    
    Parameters:
    
    partitionId - The value to set in the partitions ID field.
    
    Returns:
    
    The ClientMessage with the new partitions ID field value.
  - getDataOffset
```
public int getDataOffset()
```
    Returns the setDataOffset field.
    
    Returns:
    
    The setDataOffset type field value.
  - setDataOffset
```
public ClientMessage setDataOffset(int dataOffset)
```
    Sets the dataOffset field.
    
    Parameters:
    
    dataOffset - The value to set in the dataOffset field.
    
    Returns:
    
    The ClientMessage with the new dataOffset field value.
  - updateFrameLength
```
public ClientMessage updateFrameLength()
```
  - writeTo
```
public boolean writeTo(ByteBuffer dst)
```
  - readFrom
```
public boolean readFrom(ByteBuffer src)
```
  - isComplete
```
public boolean isComplete()
```
    Checks the frame size and total data size to validate the message size.
    
    Returns:
    
    true if the message is constructed.
  - isUrgent
```
public boolean isUrgent()
```
    Description copied from interface: OutboundFrame
    
    Checks if this Frame is urgent. Frames that are urgent, have priority above regular frames. This is useful to implement System Operations so that they can be send faster than regular operations; especially when the system is under load you want these operations have precedence.
    
    Specified by:
    
    isUrgent in interface OutboundFrame
    
    Returns:
    
    true if urgent, false otherwise.
  - isRetryable
```
public boolean isRetryable()
```
  - acquiresResource
```
public boolean acquiresResource()
```
  - setAcquiresResource
```
public void setAcquiresResource(boolean acquiresResource)
```
  - setRetryable
```
public void setRetryable(boolean isRetryable)
```
  - setOperationName
```
public void setOperationName(String operationName)
```
  - getOperationName
```
public String getOperationName()
```
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object
  - create
```
public static ClientMessage create()
```
  - createForEncode
```
public static ClientMessage createForEncode(int initialCapacity)
```
  - createForEncode
```
public static ClientMessage createForEncode(ClientProtocolBuffer buffer,
                                            int offset)
```
  - createForDecode
```
public static ClientMessage createForDecode(ClientProtocolBuffer buffer,
                                            int offset)
```
  - copy
```
public ClientMessage copy()
```
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class Object
  - equals
```
public boolean equals(Object o)
```
    Overrides:
    
    equals in class Object

Class ClientMessage

Field Summary

Fields inherited from class com.hazelcast.client.impl.protocol.util.MessageFlyweight

Constructor Summary

Method Summary

Methods inherited from class com.hazelcast.client.impl.protocol.util.MessageFlyweight

Methods inherited from class java.lang.Object

Field Detail

VERSION

BEGIN_FLAG

END_FLAG

BEGIN_AND_END_FLAGS

LISTENER_EVENT_FLAG

HEADER_SIZE

Constructor Detail

ClientMessage

Method Detail

getConnection

setConnection

wrapForEncode

wrapForDecode

getVersion

setVersion

isFlagSet

getFlags

addFlag

getMessageType

setMessageType

getFrameLength

setFrameLength

getCorrelationId

setCorrelationId

getPartitionId

setPartitionId

getDataOffset

setDataOffset

updateFrameLength

writeTo

readFrom

isComplete

isUrgent

isRetryable

acquiresResource

setAcquiresResource

setRetryable

setOperationName

getOperationName

toString

create

createForEncode

createForEncode

createForDecode

copy

hashCode

equals