LocalReadWriteProxyTransaction extends LocalProxyTransaction { @Override void sendAbort(final TransactionRequest<?> request, final Consumer<Response<?, ?>> callback) { super.sendAbort(request, callback); closedException = this::abortedException; } LocalReadWriteProxyTransaction(final ProxyHistory parent, final TransactionIdentifier identifier,
        final DataTreeSnapshot snapshot);   LocalReadWriteProxyTransaction(final ProxyHistory parent, final TransactionIdentifier identifier);   }
@Test public void testSendAbort() throws Exception { final TestProbe probe = createProbe(); final TransactionRequest<?> request = new AbortLocalTransactionRequest(TRANSACTION_ID, probe.ref()); transaction.sendAbort(request, createCallbackMock()); assertOperationThrowsException(() -> transaction.delete(PATH_1), IllegalStateException.class); }