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, writeRefpublic CommitTransactionMessage(long transactionID)
protected CommitTransactionMessage(java.io.DataInput in)
throws java.io.IOException
java.io.IOExceptionpublic CommitTransactionMessage.Response dispatch(RemoteIdentity<RemoteWorker> client, MessageHandler h) throws TransactionCommitFailedException
Messagedispatch 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.TransactionCommitFailedExceptionprotected void writeMessage(java.io.DataOutput out)
throws java.io.IOException
MessagewriteMessage in class Message<CommitTransactionMessage.Response,TransactionCommitFailedException>java.io.IOException - if the DataOutput fails.protected void writeResponse(java.io.DataOutput out,
CommitTransactionMessage.Response r)
MessageDataOutput.writeResponse in class Message<CommitTransactionMessage.Response,TransactionCommitFailedException>protected CommitTransactionMessage.Response readResponse(java.io.DataInput in)
MessageDataOutputreadResponse in class Message<CommitTransactionMessage.Response,TransactionCommitFailedException>