public class DirtyReadMessage extends Message<DirtyReadMessage.Response,AccessException>
Modifier and Type | Class and Description |
---|---|
static class |
DirtyReadMessage.Response |
Message.MessageType, Message.NoException
Modifier and Type | Field and Description |
---|---|
long |
onum |
Store |
store |
TransactionID |
tid |
exceptionClass, messageType
Modifier | Constructor and Description |
---|---|
protected |
DirtyReadMessage(java.io.DataInput in) |
|
DirtyReadMessage(TransactionID tid,
Store store,
long onum) |
Modifier and Type | Method and Description |
---|---|
DirtyReadMessage.Response |
dispatch(RemoteIdentity<RemoteWorker> client,
MessageHandler h)
Visitor method.
|
protected DirtyReadMessage.Response |
readResponse(java.io.DataInput in)
Creates a Response message of the appropriate type using the provided
DataOutput |
protected void |
writeMessage(java.io.DataOutput out)
Writes this message out on the given output stream.
|
protected void |
writeResponse(java.io.DataOutput out,
DirtyReadMessage.Response r)
Writes a Response message of the appropriate type using the provided
DataOutput . |
readObject, readRef, receive, respond, respond, send, writeObject, writeRef
public final TransactionID tid
public final Store store
public final long onum
public DirtyReadMessage(TransactionID tid, Store store, long onum)
protected DirtyReadMessage(java.io.DataInput in) throws java.io.IOException
java.io.IOException
public DirtyReadMessage.Response dispatch(RemoteIdentity<RemoteWorker> client, MessageHandler h) throws ProtocolError, AccessException
Message
dispatch
in class Message<DirtyReadMessage.Response,AccessException>
client
- the node that is issuing the request.h
- the handler to which this message is to be dispatched.ProtocolError
AccessException
protected void writeMessage(java.io.DataOutput out) throws java.io.IOException
Message
writeMessage
in class Message<DirtyReadMessage.Response,AccessException>
java.io.IOException
- if the DataOutput
fails.protected void writeResponse(java.io.DataOutput out, DirtyReadMessage.Response r) throws java.io.IOException
Message
DataOutput
.writeResponse
in class Message<DirtyReadMessage.Response,AccessException>
java.io.IOException
- if the DataOutput
fails.protected DirtyReadMessage.Response readResponse(java.io.DataInput in) throws java.io.IOException
Message
DataOutput
readResponse
in class Message<DirtyReadMessage.Response,AccessException>
java.io.IOException
- if the response is malformed, or if the DataInput
fails.