abstract class RequestMessage
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
(package private) static class |
RequestMessage.OpCode |
| Modifier and Type | Field and Description |
|---|---|
private java.lang.String |
collectionName |
private int |
id |
private RequestMessage.OpCode |
opCode |
(package private) static java.util.concurrent.atomic.AtomicInteger |
REQUEST_ID |
private MessageSettings |
settings |
| Constructor and Description |
|---|
RequestMessage(java.lang.String collectionName,
RequestMessage.OpCode opCode,
MessageSettings settings) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
backpatchMessageLength(int startPosition,
OutputBuffer buffer) |
RequestMessage |
encode(OutputBuffer buffer) |
protected abstract RequestMessage |
encodeMessageBody(OutputBuffer buffer,
int messageStartPosition) |
protected java.lang.String |
getCollectionName() |
int |
getId() |
java.lang.String |
getNamespace() |
RequestMessage.OpCode |
getOpCode() |
MessageSettings |
getSettings() |
protected void |
writeMessagePrologue(OutputBuffer buffer) |
static final java.util.concurrent.atomic.AtomicInteger REQUEST_ID
private final java.lang.String collectionName
private MessageSettings settings
private final int id
private final RequestMessage.OpCode opCode
public RequestMessage(java.lang.String collectionName,
RequestMessage.OpCode opCode,
MessageSettings settings)
protected void writeMessagePrologue(OutputBuffer buffer)
public int getId()
public RequestMessage.OpCode getOpCode()
public java.lang.String getNamespace()
public MessageSettings getSettings()
public RequestMessage encode(OutputBuffer buffer)
protected abstract RequestMessage encodeMessageBody(OutputBuffer buffer, int messageStartPosition)
protected void backpatchMessageLength(int startPosition,
OutputBuffer buffer)
protected java.lang.String getCollectionName()