public class AMQTxOperation extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
static byte |
ACK_OPERATION_TYPE |
static byte |
ADD_OPERATION_TYPE |
static byte |
REMOVE_OPERATION_TYPE |
| Constructor and Description |
|---|
AMQTxOperation() |
AMQTxOperation(byte operationType,
ActiveMQDestination destination,
java.lang.Object data,
Location location) |
| Modifier and Type | Method and Description |
|---|---|
java.lang.Object |
getData() |
Location |
getLocation() |
byte |
getOperationType() |
void |
readExternal(WireFormat wireFormat,
java.io.DataInput dis) |
boolean |
replay(AMQPersistenceAdapter adapter,
ConnectionContext context) |
void |
setData(java.lang.Object data) |
void |
setLocation(Location location) |
void |
setOperationType(byte operationType) |
void |
writeExternal(WireFormat wireFormat,
java.io.DataOutput dos) |
public static final byte ADD_OPERATION_TYPE
public static final byte REMOVE_OPERATION_TYPE
public static final byte ACK_OPERATION_TYPE
public AMQTxOperation()
public AMQTxOperation(byte operationType, ActiveMQDestination destination, java.lang.Object data, Location location)
public java.lang.Object getData()
public void setData(java.lang.Object data)
data - the data to setpublic Location getLocation()
public void setLocation(Location location)
location - the location to setpublic byte getOperationType()
public void setOperationType(byte operationType)
operationType - the operationType to setpublic boolean replay(AMQPersistenceAdapter adapter, ConnectionContext context) throws java.io.IOException
java.io.IOExceptionpublic void writeExternal(WireFormat wireFormat, java.io.DataOutput dos) throws java.io.IOException
java.io.IOExceptionpublic void readExternal(WireFormat wireFormat, java.io.DataInput dis) throws java.io.IOException
java.io.IOExceptionCopyright © 2005-2012. All Rights Reserved.