@Override
protected RemoteProxyTransaction createTransaction(final ProxyHistory parent, final TransactionIdentifier id,
final DataTreeSnapshot snapshot) {
- return new RemoteProxyTransaction(parent, TRANSACTION_ID, false, false);
+ return new RemoteProxyTransaction(parent, TRANSACTION_ID, false, false, false);
}
@Override
builder.setSequence(0L);
builder.setAbort();
final ModifyTransactionRequest request = builder.build();
- final TransactionAbortRequest received = testForwardToRemote(request, TransactionAbortRequest.class);
+ final ModifyTransactionRequest received = testForwardToRemote(request, ModifyTransactionRequest.class);
Assert.assertEquals(request.getTarget(), received.getTarget());
+ Assert.assertTrue(received.getPersistenceProtocol().isPresent());
+ Assert.assertEquals(PersistenceProtocol.ABORT, received.getPersistenceProtocol().get());
}
@Test