FlushToDiskFactory { FlushToDiskRequest createRequest(InternalDistributedMember sender, Set<InternalDistributedMember> recipients, int processorId) { return new FlushToDiskRequest(sender, recipients, processorId, this); }    }
@Test public void createRequestReturnsFlushToDiskRequest() throws Exception { assertThat(flushToDiskFactory.createRequest(sender, recipients, 1)) .isInstanceOf(FlushToDiskRequest.class); }