ChronicleSource implements MRecordSource { @Override public void close() { try { consumer.close(); } catch (Exception e) { logger.debug("Exception during closing ChronicleConsumer", e); } } ChronicleSource(String path, String consumerName);  ChronicleSource(String path, String consumerName,Long acknowledgementRate);  ChronicleSource(ChronicleConsumerFactory consumerFactory); @Override MRecord get(); @Override boolean hasRemaining(); @Override void init(); @Override void close(); @Override Kind getKind();  }
@Test public void create_noInitialize() { ChronicleSource.ChronicleConsumerFactory factory = Mockito.mock(ChronicleSource.ChronicleConsumerFactory.class); ChronicleSource source = new ChronicleSource(factory); source.close(); verify(factory, never()).create(); }