public class CommitTransactionMessage extends Message<CommitTransactionMessage.Response,TransactionCommitFailedException>
Modifier and Type | Class and Description |
---|---|
static class |
CommitTransactionMessage.Response |
Message.MessageType, Message.NoException
Modifier and Type | Field and Description |
---|---|
long |
transactionID |
exceptionClass, messageType
Modifier | Constructor and Description |
---|---|
protected |
CommitTransactionMessage(java.io.DataInput in) |
|
CommitTransactionMessage(long transactionID) |
Modifier and Type | Method and Description |
---|---|
CommitTransactionMessage.Response |
dispatch(RemoteIdentity<RemoteWorker> client,
MessageHandler h)
Visitor method.
|
protected CommitTransactionMessage.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,
CommitTransactionMessage.Response r)
Writes a Response message of the appropriate type using the provided
DataOutput . |
readObject, readRef, receive, respond, respond, send, writeObject, writeRef
public CommitTransactionMessage(long transactionID)
protected CommitTransactionMessage(java.io.DataInput in) throws java.io.IOException
java.io.IOException
public CommitTransactionMessage.Response dispatch(RemoteIdentity<RemoteWorker> client, MessageHandler h) throws TransactionCommitFailedException
Message
dispatch
in class Message<CommitTransactionMessage.Response,TransactionCommitFailedException>
client
- the node that is issuing the request.h
- the handler to which this message is to be dispatched.TransactionCommitFailedException
protected void writeMessage(java.io.DataOutput out) throws java.io.IOException
Message
writeMessage
in class Message<CommitTransactionMessage.Response,TransactionCommitFailedException>
java.io.IOException
- if the DataOutput
fails.protected void writeResponse(java.io.DataOutput out, CommitTransactionMessage.Response r)
Message
DataOutput
.writeResponse
in class Message<CommitTransactionMessage.Response,TransactionCommitFailedException>
protected CommitTransactionMessage.Response readResponse(java.io.DataInput in)
Message
DataOutput
readResponse
in class Message<CommitTransactionMessage.Response,TransactionCommitFailedException>