@Test
public void testClose() {

    ActorRef actorRef = setupActorContextWithInitialCreateTransaction(getSystem(), READ_WRITE);
    doReturn(readDataReply(null)).when(mockActorContext).executeOperationAsync(
            eq(actorSelection(actorRef)), eqReadData(), any(Timeout.class));
    TransactionProxy transactionProxy = new TransactionProxy(mockComponentFactory, READ_WRITE);
    transactionProxy.read(TestModel.TEST_PATH);
    transactionProxy.close();
    verify(mockActorContext).sendOperationAsync(
            eq(actorSelection(actorRef)), isA(CloseTransaction.class));
}