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, writeRef
public final TransactionID tid
public AbortTransactionMessage(TransactionID tid)
protected AbortTransactionMessage(java.io.DataInput in) throws java.io.IOException
java.io.IOException
public AbortTransactionMessage.Response dispatch(RemoteIdentity<RemoteWorker> client, MessageHandler h) throws AccessException
Message
dispatch
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.AccessException
protected void writeMessage(java.io.DataOutput out) throws java.io.IOException
Message
writeMessage
in class Message<AbortTransactionMessage.Response,AccessException>
java.io.IOException
- if the DataOutput
fails.protected void writeResponse(java.io.DataOutput out, AbortTransactionMessage.Response r)
Message
DataOutput
.writeResponse
in class Message<AbortTransactionMessage.Response,AccessException>
protected AbortTransactionMessage.Response readResponse(java.io.DataInput in)
Message
DataOutput
readResponse
in class Message<AbortTransactionMessage.Response,AccessException>