FlushToDiskFactory { FlushToDiskProcessor createReplyProcessor(DistributionManager dm, Set<InternalDistributedMember> recipients) { return new FlushToDiskProcessor(dm, recipients); }    }
@Test public void createReplyProcessorReturnsFlushToDiskReplyProcessor() throws Exception { assertThat(flushToDiskFactory.createReplyProcessor(dm, recipients)) .isInstanceOf(FlushToDiskProcessor.class); }