public class WriteRequest extends AbstractWriteRequest<java.lang.Integer>
Modifier and Type | Field and Description |
---|---|
protected int |
sequenceNumber |
items
Constructor and Description |
---|
WriteRequest(NodeMapDriver driver,
java.util.List<? extends WriteItem> items) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
getKey() |
ReceiveAction |
receiveMessage(java.lang.Integer message,
java.lang.Object key)
Called when a response message is received for this Request.
|
boolean |
sendMessage()
Creates and puts the
Request s message "on the wire". |
fail, getPriority, getTimeout, isRetryAllowed
public WriteRequest(NodeMapDriver driver, java.util.List<? extends WriteItem> items)
public java.lang.Object getKey()
Request
.public ReceiveAction receiveMessage(java.lang.Integer message, java.lang.Object key)
Request
ReadItem
s or WriteItem
s that it contains (if applicable).
If you are extending from AbstractSocketDriver
you must do this work on the thread this call arrived on
or risk the byte[] message being returned its pool and reused in the middle of processing it.message
- The message that was received for this Request.key
- The key used to retrieve this Request.ReceiveAction
that indicates what the driver should do with this request.