- } else if (message instanceof PersistAbortTransactionPayload) {
- final TransactionIdentifier txId = ((PersistAbortTransactionPayload) message).getTransactionId();
- persistPayload(txId, AbortTransactionPayload.create(txId,
- datastoreContext.getInitialPayloadSerializedBufferCapacity()), true);
- persistPayload(txId, PurgeTransactionPayload.create(txId,
- datastoreContext.getInitialPayloadSerializedBufferCapacity()), false);