@Test(expected = ReadFailedException.class)
public void testReadWithInvalidReplyMessageType() throws Throwable {

    ActorRef actorRef = setupActorContextWithInitialCreateTransaction(getSystem(), READ_ONLY);
    doReturn(Futures.successful(new Object())).when(mockActorContext)
            .executeOperationAsync(eq(actorSelection(actorRef)), eqReadData(), any(Timeout.class));
    TransactionProxy transactionProxy = new TransactionProxy(mockComponentFactory, READ_ONLY);
    try {
        transactionProxy.read(TestModel.TEST_PATH).get(5, TimeUnit.SECONDS);
    } catch (ExecutionException e) {
        throw e.getCause();
    }
}