public class AMQTxOperation extends 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,
Object data,
Location location) |
| Modifier and Type | Method and Description |
|---|---|
Object |
getData() |
Location |
getLocation() |
byte |
getOperationType() |
void |
readExternal(WireFormat wireFormat,
DataInput dis) |
boolean |
replay(AMQPersistenceAdapter adapter,
ConnectionContext context) |
void |
setData(Object data) |
void |
setLocation(Location location) |
void |
setOperationType(byte operationType) |
void |
writeExternal(WireFormat wireFormat,
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, Object data, Location location)
public 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 IOException
IOExceptionpublic void writeExternal(WireFormat wireFormat, DataOutput dos) throws IOException
IOExceptionpublic void readExternal(WireFormat wireFormat, DataInput dis) throws IOException
IOExceptionCopyright © 2005–2017. All rights reserved.