public class AbortTransactionMessage extends Message<AbortTransactionMessage.Response,AccessException>
| Modifier and Type | Class and Description |
|---|---|
static class |
AbortTransactionMessage.Response |
Message.MessageType, Message.NoException| Modifier and Type | Field and Description |
|---|---|
TransactionID |
tid
The tid for the transaction that is aborting.
|
exceptionClass, messageType| Modifier | Constructor and Description |
|---|---|
protected |
AbortTransactionMessage(java.io.DataInput in) |
|
AbortTransactionMessage(TransactionID tid) |
| Modifier and Type | Method and Description |
|---|---|
AbortTransactionMessage.Response |
dispatch(RemoteIdentity<RemoteWorker> client,
MessageHandler h)
Visitor method.
|
protected AbortTransactionMessage.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,
AbortTransactionMessage.Response r)
Writes a Response message of the appropriate type using the provided
DataOutput. |
readObject, readRef, receive, respond, respond, send, writeObject, writeRefpublic final TransactionID tid
public AbortTransactionMessage(TransactionID tid)
protected AbortTransactionMessage(java.io.DataInput in)
throws java.io.IOException
java.io.IOExceptionpublic AbortTransactionMessage.Response dispatch(RemoteIdentity<RemoteWorker> client, MessageHandler h) throws AccessException
Messagedispatch in class Message<AbortTransactionMessage.Response,AccessException>client - the node that is issuing the request.h - the handler to which this message is to be dispatched.AccessExceptionprotected void writeMessage(java.io.DataOutput out)
throws java.io.IOException
MessagewriteMessage in class Message<AbortTransactionMessage.Response,AccessException>java.io.IOException - if the DataOutput fails.protected void writeResponse(java.io.DataOutput out,
AbortTransactionMessage.Response r)
MessageDataOutput.writeResponse in class Message<AbortTransactionMessage.Response,AccessException>protected AbortTransactionMessage.Response readResponse(java.io.DataInput in)
MessageDataOutputreadResponse in class Message<AbortTransactionMessage.Response,AccessException>