return msg;
}
private CleanedTransactionReport decodeFullAbort(byte type, ChannelBuffer buffer) {
CleanedTransactionReport msg;
if (type == TSOMessage.CleanedTransactionReport) {
msg = new CleanedTransactionReport();
msg.readObject(buffer);
} else {
msg = new CleanedTransactionReport();
int diff = buffer.readByte();
msg.startTimestamp = lastFullAbortedTimestamp + diff;
}
lastFullAbortedTimestamp = msg.startTimestamp;