SnapshotConnectorFactory extends SharedConnectorBasedConnectorFactory { @Override public StorageConnector createConnector() { ensureOpen(); return new SnapshotStorageConnector(centralConnector); } SnapshotConnectorFactory(DriverConfiguration configuration); @Override StorageConnector createConnector();  }
@Test public void createConnectorCreatesNewSnapshotBasedStorageConnector() throws Exception { final DriverConfiguration configuration = StorageTestUtil.createConfiguration("test:uri"); final ConnectorFactory factory = connectorFactory(configuration); final StorageConnector connector = factory.createConnector(); assertTrue(connector instanceof SnapshotStorageConnector); assertNotNull(getCentralConnector(factory)); assertTrue(getCentralConnector(factory).isOpen()); }